OCI GoldenGateを使用して、Autonomous AI Lakehouseにデータをステージングおよびマージします

始める前に

続行するには、次のものが必要です:

既存のソース・データベース
既存のターゲットAutonomous AI Lakehouse。
一時ステージング領域として使用される既存のOracle Object Storageバケット。
Autonomous AI Lakehouseのステージおよびマージ・レプリケーションを構成する前に、ターゲット・スキーマおよび表をターゲットのAutonomous AI Lakehouseインスタンスに作成する必要があります。
Archive.zipをダウンロードし、タスク0に従って、Autonomous AI Lakehouseを使用してソース・データベースとターゲット・データベースを設定できます。

タスク0: ソース&ターゲットAutonomous Databasesの設定

サンプル・データベース・スキーマをダウンロードして解凍します。
ソースのAutonomous AI Transaction Processingを設定します:
1. Oracle Cloudコンソールで、「Autonomous AI Database」ページから「Autonomous AI Transaction Processing」インスタンスを選択して、その詳細を表示し、データベース・アクションにアクセスします。
2. 「データベース・アクション」をクリックします。
3. GGADMINユーザーを有効にします:
  1. 「管理」の下で、「データベース・ユーザー」をクリックします。
  2. GGADMINを見つけて、その省略記号メニュー(3つのドット)をクリックし、「編集」を選択します。
  3. 「ユーザーの編集」パネルで、GGADMINパスワードを入力し、パスワードを確認して「アカウントはロックされています」を無効にします。
  4. 「変更の適用」をクリックします。
4. ソース・サンプル・スキーマおよびデータをロードします:
  1. データベース・アクション・セレクタ・メニューの開発で、SQLを選択します。
  2. OCIGGLL_OCIGGS_SETUP_USERS_ATP.sqlからスクリプトをコピーしてSQLワークシートに貼り付けます。
  3. 「スクリプトの実行」をクリックします。「スクリプトの出力」タブには、確認メッセージが表示されます。
  4. SQLワークシートをクリアし、OCIGGLL_OCIGGS_SRC_USER_SEED_DATA.sqlからSQLスクリプトをコピーして貼り付けます。
  ヒント:
  SQLツールでスクリプトを正常に実行するには、各文を個別に実行する必要がある場合があります。
5. 表が正常に作成されたことを確認するには、SQLウィンドウを閉じて再度開きます。ナビゲータ・タブで、SRC_OCIGGLLスキーマを探し、それぞれのドロップダウンから表を選択します。
6. サプリメンタル・ロギングを有効化します。
  1. SQLワークシートをクリアします。
  2. 次の文を入力し、文の実行をクリックします:
```
ALTER PLUGGABLE DATABASE ADD SUPPLEMENTAL LOG DATA;
```
ターゲットのAutonomous AI Lakehouseを設定します:
1. Oracle Cloudコンソールで、「Autonomous AI Database」ページから「Autonomous AI Lakehouse」インスタンスを選択して、その詳細を表示し、DBツールにアクセスします。
2. 「データベース・アクション」をクリックします。
3. データベース・アクション・メニューの開発で、SQLを選択します。
4. 以前にダウンロードしたOCIGGLL_OCIGGS_SETUP_USERS_ADW.sqlからSQLワークシートにスクリプトをコピーして貼り付けます。
5. 「スクリプトの実行」をクリックします。「スクリプトの出力」タブには、確認メッセージが表示されます。
6. SQLワークシートをクリアし、OCIGGLL_OCIGGS_SRC_MIRROR_USER_SEED_DATA.sqlからSQLスクリプトをコピーして貼り付けます
7. 「スクリプトの実行」をクリックします。

タスク1: OCI GoldenGateリソースの作成

このクイックスタートの例では、ソースとターゲットの両方のデプロイメントおよび接続が必要です。

ソースAutonomous AI Transaction ProcessingインスタンスのOracleデプロイメントを作成します。
ターゲットAutonomous AI Lakehouseのビッグ・データ・デプロイメントを作成します。
ソースのAutonomous AI Transaction Processingインスタンスの接続を作成します。
ターゲットのAutonomous AI Lakehouseインスタンスの接続を作成します。
Oracle Object Storageの接続を作成します。
「GoldenGateへの接続の作成」、次に「この接続をソースOracleデプロイメントに割り当て」ます。
Autonomous AI Transaction Processing接続をソースOracleデプロイメントに割り当てます。
Autonomous AI Lakehouse接続をターゲット・ビッグ・データ・デプロイメントに割り当てます。
Oracle Object Storage接続をターゲット・ビッグ・データ・デプロイメントに割り当てます。

タスク2: 抽出の追加

「デプロイメント」ページで、ソースのOracleデプロイメントを選択します。
デプロイメントの詳細ページで、「コンソールの起動」をクリックします。
ソース・デプロイメント管理者のユーザー名とパスワードを使用してログインします。
トランザクション情報の追加。
「抽出」の追加。

タスク3: 「分散パス」を追加して実行

GoldenGate資格証明ストアを使用する場合は、ターゲット・ビッグ・データ・デプロイメントで分散パスのユーザーを作成します:
1. デプロイメント・ページで、ターゲット・デプロイメントを選択して詳細を表示します。
2. デプロイメントの詳細ページで、「コンソールの起動」をクリックします。
3. 管理者のユーザー名とパスワードを使用して、ターゲット「OCI GoldenGateデプロイメント・コンソール」にサインインします。
4. 「OCI GoldenGateデプロイメント・コンソール」で、ナビゲーション・メニューを開き、「ユーザー管理」をクリックします。
5. ユーザー・ページで、「新しいユーザーを追加」 (プラス・アイコン)をクリックします。
6. 次のようにフィールドに入力し、「送信」をクリックします。
  - 「認証者」ドロップダウンから、「パスワード」を選択します。
  - 「ロール」ドロップダウンから、「オペレータ」を選択します。
  - 「ユーザー名」には、ggsnetなどの名前を入力します。
  - 確認のためにパスワードを2回入力します。
新規ユーザーがユーザー・リストに表示されます。
ソースATPデプロイメント・コンソールで、ステップ1で作成したユーザーの資格証明を追加します。
1. ソースATPデプロイメント・コンソールで、「管理サービス」をクリックし、ナビゲーション・メニューを開き、「構成」を選択します。
2. 資格証明ページで、資格証明の追加をクリックし、次のようにフィールドに入力します:
  - 「資格証明ドメイン」には、GGSNetworkと入力します。
  - 「資格証明別名」には、dpuserと入力
  - 「ユーザーID」には、ステップ1 (ggsnet)で作成したユーザーの名前を入力
  - 確認のためにユーザー・パスワードを2回入力します。
3. 「送信」をクリックします。
資格証明が資格証明リストに表示されます。
「分散サービス」をクリックし、「分散パスの追加」 (プラス・アイコン)をクリックします。
分散パスの追加に次の値を指定し、パスの作成および実行をクリックします:
1. 「パスの情報」ページで、「パス名」に名前を入力します。
2. 「ソース・オプション」ページで、次の手順を実行します:
  - 「ソースの抽出」で、タスク2で作成したExtractを選択します。
  - 「トレイル名」に、2文字の名前(E1など)を入力します。
3. 「ターゲット・オプション」ページで、次の手順を実行します:
  - 「ターゲット・ホスト」に、ターゲット・デプロイメントのホスト・ドメインを入力します。
    
    ノート:
    ターゲット「OCI GoldenGateデプロイメント・コンソール」のURLをコピーして貼り付け、https://および末尾のスラッシュを削除できます。
  - 「ポート番号」には、443と入力します。
  - 「トレイル名」に、2文字の名前(E1など)を入力します。
  - 「別名」に、ステップ2で作成した資格証明別名(dpuser)を入力します。
「分散サービス」の「概要」ページに戻り、作成したパスのステータスを表示できます。
ターゲットのビッグ・データ・デプロイメント・コンソールで、「受信パス」を確認します。
1. ターゲットのビッグ・データ「OCI GoldenGateデプロイメント・コンソール」で、「受信サービス」をクリックします。
2. 「受信パス」の詳細を確認します。このパスは、前のステップで作成した「受信パス」の結果として作成されました。

タスク4: Replicatの追加と実行

ターゲットのビッグ・データ・デプロイメント・コンソールで、「管理者サービス」をクリックし、「Replicatの追加」 (プラス・アイコン)をクリックします。
次の値を含むReplicatの追加:
1. Replicat情報ページのReplicatタイプで、「クラシックReplicat」を選択し、プロセス名を入力します。
2. Replicatオプション・ページで、次の手順を実行します:
  - 「名前」に、タスク2からのトレイルの名前を入力します。
  - 「ドメイン」で、ドメインを選択します。
  - 「別名」で、タスク1で作成されたOracle Object Storage接続およびAutonomous AI Lakehouse接続を選択します。
  - 「チェックポイント表」で、ターゲット・デプロイメント用に作成したチェックポイント表を選択します。
3. 「管理オプション」ページで、フィールドはそのままにして、「次」をクリックします。
4. Replicatパラメータ・ページで、MAP行を次のように変更します:
```
MAP SRC_OCIGGLL.*, TARGET SRCMIRROR_OCIGGLL.*;
```
プロパティ・ページで、次のプロパティを構成します:
1. gg.eventhandler.oci.compartmentID: Oracle Object Storageバケットが格納されているコンパートメントのOCIDを追加します。
2. gg.eventhandler.oci.bucketMappingTemplate: Oracle Object Storageバケットの名前を追加します。
「Create and Run」をクリックします

「概要」ページに戻り、Replicatの詳細を確認します。

タスク5: レプリケーションの検証

Oracle Cloudコンソールで、ナビゲーション・メニューから「Oracle AI Database」を選択し、「Autonomous AI Transaction Processing」を選択します。
Autonomous AI Transaction Processingインスタンスのリストで、その詳細を表示するソース・インスタンスを選択します。
データベースの詳細ページで、「データベース・アクション」をクリックします。

ノート:
自動的にログインする必要があります。そうでない場合は、データベース資格証明を使用してログインします。
データベース・アクションのホームページで、SQLを選択します。
ワークシートに次を入力し、「スクリプトの実行」をクリックします。

ソースのGoldenGate OCI GoldenGateデプロイメント・コンソールで、「抽出」名を選択し、「統計」をクリックします。 SRC_OCIGGLL.SRC_CUSTOMERに7つの挿入があることを確認します。

Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1001,0,'Brendt','Paul','10 Jasper Blvd.',107,'(212) 555 2146',19,10);
Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1002,0,'McCarthy','Robin','27 Pasadena Drive',11,'(214) 555 3075',29,11);
Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1003,0,'Travis','Peter','7835 Hartford Drive',12,'(510) 555 4448',34,12);
Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1004,0,'Larson','Joe','87 Carmel Blvd.',13,'(213) 555 5095',45,13);
Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1005,0,'Goldschmidt','Tony','91 Torre drive',14,'(619) 555 6529',55,20);
Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1006,0,'Baker','William','2890 Grant Avenue',15,'(312) 555 7040',64,21);
Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1007,0,'Swenson','Jack','64 Imagination Drive',19,'(202) 555 8125',74,22);

ターゲットのビッグ・データ・デプロイメント・コンソールで、Replicat名を選択し、「統計」をクリックします。 SRC_OCIGGLL.SRC_CUSTOMERに7つの挿入があることを確認します。
ターゲットのAutonomous AI Lakehouse Cloud SQLコンソールで、次のコマンドを実行して、レプリケートされたデータを検証します:
```
select * from SRCMIRROR_OCIGGLL.SRC_CUSTOMER;
```