OCI GoldenGateを使用したAutonomous AI Lakehouseへのデータのステージングとマージ

このクイックスタートでは、OCI GoldenGate Big Dataデプロイメントを使用して、Autonomous AI Transaction ProcessingからAutonomous AI Lakehouseにデータをステージングおよびマージする方法について説明します。

開始する前に

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

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

環境設定: Autonomous AI Databases

サンプル・データベース・スキーマをダウンロードして解凍します。
ソースのAutonomous AI Transaction Processingを設定します:
1. Oracle Cloudコンソールで、「Autonomous AIデータベース」ページから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 Databases」ページから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リソースの作成

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

タスク2: Extractの追加

「デプロイメント」ページで、ソースAutonomous AI Transaction Processingデプロイメントを選択します。
デプロイメントの詳細ページで、「コンソールの起動」を選択します。
ソース・デプロイメントの管理者のユーザー名とパスワードでログインします。
Extractを追加します

タスク3: 分散パスの追加および実行

GoldenGate資格証明ストアを使用する場合は、ターゲット・ビッグ・データ・デプロイメントで分散パスのユーザーを作成し、それ以外の場合はステップ3にスキップします。
ソースGoldenGateデプロイメント・コンソールで、ステップ1で作成したユーザーのパス接続を追加します。
1. ソースGoldenGateデプロイメント・コンソールで、左側のナビゲーションで「パス接続」を選択します。
2. 「パス接続の追加」(プラス・アイコン)を選択し、次を完了します:
  1. 「資格証明別名」に、GGSNetworkと入力します。
  2. 「ユーザーID」に、ステップ1で作成したユーザーの名前を入力します。
  3. 確認のためにユーザーのパスワードを2回入力します。
3. 「送信」を選択します。
  
  「パス接続」リストにパス接続が表示されます。
ソース・デプロイメント・コンソールで、次の値を含む分散パスを追加します:
1. 「ソース・オプション」ページで、次の手順を実行します。
  - 「ソースExtract」で、タスク2で作成したExtractを選択します。
  - 「トレイル名」に、2文字の名前(E1など)を入力します。
2. 「ターゲット・オプション」ページで、次の手順を実行します。
  - 「ターゲット・ホスト」に、ターゲット・デプロイメントのホスト・ドメインを入力します。
  - 「ポート番号」に、443と入力します。
  - 「トレイル名」に、2文字の名前(E1など)を入力します。
  - 「別名」に、ステップ2で作成した資格証明別名を入力します。
ターゲット・ビッグ・データ・デプロイメント・コンソールで、分散パスの結果として作成された受信パスの確認を行います。
1. ターゲットのビッグ・データ・デプロイメント・コンソールで、「受信サービス」を選択します。
2. パスの詳細を確認します。このパスは、前のステップで作成した分散パスの結果として作成されました。

タスク4: Replicatの追加および実行

ターゲットのビッグ・データ・デプロイメント・コンソールで、「Administrator Service」を選択し、「Add 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バケットの名前を追加します。
「作成および実行」を選択します。

タスク5: レプリケーションの確認

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

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

ソースGoldenGateのOCI GoldenGateデプロイメント・コンソールで、Extract名を選択し、「統計」を選択します。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;
```