機械翻訳について

HeatWaveからAzureイベント・ハブへのデータの送信

OCI GoldenGateを使用して、HeatWaveから「Azureイベント・ハブ」にデータをレプリケートする方法を学習します。

始める前に

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

• OCIバスチョン、HeatWaveデータベースに接続し、サンプル・データベースをロードして、挿入を実行します。
• ソース・データベースとして機能するHeatWaveデータベース。
• 作成されたAzure Event Hubsネームスペースおよびイベント・ハブ

  ノート:

  Kafkaサーフェスは、Azure Event Hubs Basic Tierでは有効になりません。 StandardまたはPremium層が必要です。

環境設定: HeatWave

このクイックスタートの環境を設定するには:

1. サンプル・データ・スクリプトのダウンロード。次に、HeatWaveデータベースでスクリプトを実行し、データベースを作成してデータをロードします。
2. 次のスクリプトを使用してggadminユーザーを作成します。 <ggadmin-password>を有効なパスワードに置き換えてください:

   CREATE USER 'ggadmin' IDENTIFIED BY '<ggadmin-password>';
   GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT, CREATE,CREATE VIEW, EVENT, INSERT, UPDATE, DROP,EXECUTE, DELETE ON *.* TO 'ggadmin';

3. OCI GoldenGateが接続できるport 3306を開きます。
   1. Oracle Cloudコンソールで、HeatWaveデータベースが使用するサブネットを見つけます。
   2. サブネットのセキュリティ・リストで、port TCP/3306のイングレス・ルールを作成します。

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

1. ソースHeatWaveデータベースに「MySQLデプロイメントを作成」します。
2. ターゲットAzure Event Hubsに「ビッグ・データ・デプロイメントを作成」します。
3. ソースのMySQL Heatwaveデータベースへの接続を作成します。
4. Azure Event Hubs接続の作成。
5. GoldenGateへの接続を作成し、次にこの接続をソースMySQLデプロイメントに割り当てます。
6. ソース接続をソースのMySQLデプロイメントに割り当てます。
7. ターゲットのビッグ・データ・デプロイメントへのターゲット接続の割当て。

タスク2: 「抽出」の作成

1. 「デプロイメント」ページで、タスク1で作成したMySQLデプロイメントを選択します。
2. デプロイメントの詳細ページで、「コンソールの起動」をクリックします。
3. タスク1でデプロイメントを作成したときに指定した管理者資格証明を使用して、ソースのMySQLデプロイメント・コンソールにサインインします。
4. 次の値を含む変更データ取得抽出の追加:
   • 抽出タイプ: 変更データ取得抽出
   • プロセス名: ECDC
   • 抽出トレイル名前: C1
   • パラメータ・ファイル: MAP *.*, TARGET *.*;をTABLE SRC_OCIGGLL.*;に置き換えます

タスク3: ビッグ・データ・デプロイメントをターゲットとする「分散パス」を作成

1. IAM資格証明ストアを使用している場合は、ステップ3に進みます。 GoldenGate資格証明ストアを使用する場合は、ソースGoldenGateがターゲットGoldenGateへの接続に使用するユーザーを作成します。
   1. 「デプロイメント」ページで、「ターゲット」ビッグ・データ・デプロイメントを選択します。
   2. デプロイメントの詳細ページで、「コンソールを起動」をクリックし、管理者ユーザーとしてログインします。
   3. デプロイメント・コンソールのナビゲーション・メニューで、「ユーザー管理」をクリックします。
   4. 新しいユーザーを追加 (プラス・アイコン)をクリックし、次のようにフィールドに入力して、送信をクリックします:
      • 「ユーザー名」には、ggsnetと入力します。
      • 「ロール」で、「オペレータ」を選択します。
      • 確認のためにパスワードを2回入力します。
2. 「ソース」 MySQLデプロイメント・コンソールで、前のステップで作成したユーザーの「パス接続」を作成します。
   1. ナビゲーション・メニューを開き、「パス接続」をクリックします。
   2. 「パス接続の追加」(プラス・アイコン)をクリックし、次のようにフィールドに入力して、送信をクリックします:
      • 「資格証明別名」には、dpuserと入力します。
      • 「ユーザーID」には、ggsnetと入力
      • 「パスワード」には、前のステップで使用したものと同じパスワードを入力します。
3. ソース MySQLデプロイメント・コンソールの分散パスの追加で、次の値を使用します:
   1. ソース・オプションページで、次の手順を実行します:
      • ソース「抽出」で、タスク2で作成した「抽出」を選択します。
      • 「トレイル名」に、2文字の名前(C1など)を入力します。
   2. ターゲット・オプションページで、次の手順を実行します:
      • 「ターゲット・ホスト」に、ターゲット・デプロイメントのホスト・ドメインを入力します。
      • 「ポート番号」には、443と入力します。
      • 「トレイル名」に、2文字の名前(C1など)を入力します。
      • 「別名」に、ステップ2で作成した資格証明別名を入力します。
4. ターゲットOCIのGoldenGateビッグ・データ・デプロイメント・コンソールで、分散パスの結果として作成された受信パスを確認します:
   1. 「受信サービス」をクリックします。
   2. 「受信パス」の詳細を確認します。

タスク4: 「Azureイベント・ハブ」にReplicatを追加

1. ビッグ・データ・デプロイメントで、「管理者サービス」をクリックし、「Replicatの追加」(プラス・アイコン)をクリックします。
2. 次の値を含むReplicatの追加:
   1. Replicat情報ページのReplicatタイプで、「クラシックReplicat」を選択し、プロセス名を入力します。
   2. Replicatオプション・ページで、次の手順を実行します:
      • 「トレイル名」に、タスク2からの証跡の名前を入力します。
      • 「ターゲット」で、「Azureイベント・ハブ」を選択します。
      • 「別名」で、タスク1で作成した「Azureイベント・ハブ」接続を選択します。
   3. Replicatパラメータ・ページで、デフォルトのままにします。
   4. 「プロパティ・ファイル」ページで、topicMappingTemplateのトピック名を指定します。
   5. 「Create and Run」をクリックします

タスク5: HeatWaveから「Azureイベント・ハブ」へのデータ・レプリケーションの検証

ソースHeatWaveデータベースの更新を実行して、「Azureイベント・ハブ」へのレプリケーションを確認します。

1. OCI Bastionで、MySQL IPおよびport 3306を使用してSSHポート転送セッションを作成します。 公開SSHキーを追加します。
2. 秘密キーとport 3306を使用して、Cloud ShellのMySQLに接続します。
3. 正常に接続した後、次のコマンドを実行します:

   mysqlsh admin@localhost:3306 --sql

4. 次のスクリプトを実行して、HeatWaveデータベースへの挿入を実行します:

   use SRC_OCIGGLL;
   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);
   commit;

5. ソースのMySQLデプロイメント・コンソールで、「変更データ取得抽出」名を選択し、「統計」をクリックします。 SRC_OCIGGLL.SRC_CITYに10個の挿入があることを確認します。
6. ターゲット・ビッグ・データ・デプロイメント・コンソールで、Replicat名を選択し、「統計」をクリックします。 SRC_OCIGGLL.SRC_CITYに10個の挿入があることを確認します。
7. Azure Event Hubsでは、メッセージ統計を確認できます。

---

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

Copyright ©2023,2024,

Oracle and/or its affiliates.