機械翻訳について

Autonomous Transaction ProcessingからApache Icebergへのデータのレプリケート

OCI GoldenGateで、Autonomous Transaction ProcessingからApache Icebergにデータをレプリケートする方法を確認します。

始める前に

このクイックスタートを正常に完了するには、次のものが必要です:

• ソースAutonomous Transaction Processing
• ターゲットのApache Iceberg環境:
  • OCI GoldenGateは、Apache Iceberg表のストレージ・サービスとして、「Azure Data Lakeストレージ」、Amazon S3およびGoogle Cloud Storageをサポートします。
  • OCI GoldenGateでは、Apache IcebergのHadoop、Nessie、AWS Glue、Polaris、RESTおよびJDBCカタログがサポートされています。

環境設定: Autonomous Transaction Processing

レプリケーション用のソース・データベースが設定されていない場合は、次のステップに従って、このクイックスタートに使用するサンプル・スキーマをロードできます。 このクイックスタートでは、ソース・データベースにAutonomous Transaction Processingを使用します。

ソースAutonomous Databaseを設定するには:

1. サンプル・データベース・スキーマをダウンロードして解凍します。
2. Oracle Cloudコンソールで、Autonomous DatabasesページからAutonomous Transaction Processing (ATP)インスタンスを選択して、その詳細を表示し、データベース・アクションにアクセスします。
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スキーマを探し、それぞれのドロップダウンから表を選択します。
5. サプリメンタル・ロギングを有効化します。
   1. SQLワークシートをクリアします。
   2. 次の文を入力し、文の実行をクリックします:

      ALTER PLUGGABLE DATABASE ADD SUPPLEMENTAL LOG DATA;

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

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

1. ソースAutonomous Transaction Processingインスタンスの「Oracleデプロイメントの作成」。
2. Apache Icebergターゲットの「ビッグ・データ・デプロイメントの作成」。
3. Autonomous Transaction Processing接続の作成。
4. Apache Iceberg接続の作成。
5. GoldenGateサーバー接続の作成およびOracleデプロイメントへの割当て。
6. OracleデプロイメントへのATP接続の割当て。
7. ビッグ・データ・デプロイメントへのIceberg接続の割当て。

タスク2: 「抽出」を追加

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

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

1. GoldenGate資格証明ストアを使用する場合、「ターゲット」ビッグ・データ・デプロイメントで「分散パスのユーザーの作成」を使用し、それ以外の場合はステップ3にスキップします。
2. 「ソース」 ATP GoldenGateデプロイメント・コンソールで、ステップ1で作成したユーザーのパス接続を追加します。
   1. ソースATPのGoldenGateデプロイメント・コンソールで、左側のナビゲーションで「パス接続」をクリックします。
   2. パス接続の追加 (プラス・アイコン)をクリックし、次の操作を完了します:
      1. 「資格証明別名」には、GGSNetworkと入力します。
      2. 「ユーザーID」に、ステップ1で作成したユーザーの名前を入力します。
      3. 確認のためにユーザー・パスワードを2回入力します。
   3. 「送信」をクリックします。

      「パス接続」リストにパス接続が表示されます。

3. ソース ATPデプロイメント・コンソールで、分散パスの追加に次の値を指定します:
   1. ソース・オプションページで、次の手順を実行します:
      • 「ソースの抽出」で、タスク2で作成したExtractを選択します。
      • 「トレイル名」に、2文字の名前(E1など)を入力します。
   2. ターゲット・オプションページで、次の手順を実行します:
      • 「ターゲット・ホスト」に、ターゲット・デプロイメントのホスト・ドメインを入力します。
      • 「ポート番号」には、443と入力します。
      • 「トレイル名」に、2文字の名前(E1など)を入力します。
      • 「別名」に、ステップ2で作成した資格証明別名を入力します。
4. 「ターゲット」ビッグ・データ・デプロイメント・コンソールで、「分散パス」の結果として作成された「受信パス」を確認します。
   1. ターゲットのビッグ・データ・デプロイメント・コンソールで、「受信サービス」をクリックします。
   2. パス詳細を確認します。 このパスは、前のステップで作成した「分散パス」の結果として作成されました。

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

Replicatを追加して実行するには:

1. 「OCI GoldenGateデプロイメント・コンソール」の「管理サービス」ホーム・ページで、Replicatの追加(プラス・アイコン)をクリックします。
2. 「Replicatの追加」パネルのReplicat情報ページで、必要に応じてフィールドに入力し、次をクリックします:
   • Replicatタイプで、「クラシック」Replicatを選択
   • 5文字以下の「プロセス名」を入力します。
   • 「説明」と入力すると、このプロセスが他のプロセスと区別しやすくなります。
3. Replicatオプションページで、必要に応じてフィールドに入力し、次をクリックします:
   1. 「Replicat Trail」に、Extract証跡名を入力します。
   2. 「ターゲット」の場合は、Apache Icebergを選択します。
   3. 「フォーマット」で、Apache Icebergに収集する形式を選択します。 デフォルトはParquetです。
   4. 「使用可能な別名」の場合は、ドロップダウンからApache Iceberg接続を選択します。
4. 「管理オプション」ページで、デフォルト設定のままにして「次」をクリックします。
5. 「Replicatパラメータ」ページで、デフォルト設定のままにして、「次」をクリックします。
6. 「Replicatのプロパティ」ページで、TODOとマークされたフィールドを更新し、「作成および実行」をクリックします。
   詳細については、「Apache Icebergターゲットの詳細」を参照してください。

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

レプリケーションを検証するには、ソースATPインスタンスに対する更新を実行します。

1. Oracle Cloudコンソールで、ナビゲーション・メニューを開き、Oracle Databaseを選択し、Autonomous Databaseを選択します。
2. Autonomous Databasesのリストで、その詳細を表示するソース・インスタンスを選択します。
3. データベースの詳細ページで、「データベース・アクション」をクリックします。
4. データベース・アクション・ページで、SQLを選択します。
5. 次の挿入文をSQL ワークシートに入力し、スクリプトの実行をクリックします:

   Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1000,'Houston',20,743113);
   Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1001,'Dallas',20,822416);
   Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1002,'San Francisco',21,157574);
   Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1003,'Los Angeles',21,743878);
   Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1004,'San Diego',21,840689);
   Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1005,'Chicago',23,616472);
   Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1006,'Memphis',23,580075);
   Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1007,'New York City',22,124434);
   Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1008,'Boston',22,275581);
   Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1009,'Washington D.C.',22,688002);

6. ソースATPデプロイメント・コンソールで、Extract名を選択し、「統計」をクリックします。 SRC_OCIGGLL.SRC_CITYに10個の挿入があることを確認します。
7. ターゲットのビッグ・データ・デプロイメント・コンソールで、Replicat名を選択し、「統計」をクリックします。 SRC_OCIGGLL.SRC_CITYに10個の挿入があることを確認します。

---

タイトルおよび著作権情報

Copyright ©2025,2025,

Oracle and/or its affiliates.