HeatWaveからGoogle Cloud Storageへのデータ・レプリケート

OCI GoldenGateを使用して、HeatWaveからGoogle Cloud Storageにデータをレプリケートする方法を学習します。

開始する前に

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

OCI Bastionは、HeatWaveデータベースに接続し、サンプル・データベースをロードして、挿入を実行します。
ソース・データベースとして機能するHeatWaveデータベース。
Google Cloud StorageアカウントおよびGoogle Cloud Serviceアカウント・キー
Google Cloudストレージ・バケットおよびオブジェクト権限

環境設定: HeatWave

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

サンプル・データ・スクリプトをダウンロードしますし、OCIデータベースでHeatWaveでスクリプトを実行してデータベースの作成とデータのロードを行います。

次のスクリプトを使用して、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';

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

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

タスク2: Extractの作成

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

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

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

タスク4: Google Cloud StorageのReplicatの追加

ビッグ・データ・デプロイメントで、「Replicat」、「Replicatの追加(プラス・アイコン)」の順に選択します。
次の値を使用してReplicatを追加します:
1. 「Replicat情報」ページの「Replicatタイプ」で、「クラシックReplicat」を選択し、プロセス名を入力します。
2. 「Replicatオプション」ページで、次の手順を実行します。
  - 「名前」に、タスク2からトレイルの名前を入力します。
  - 「ターゲット」で、「Google Cloud Storage」を選択します。
  - 「別名」で、タスク1で作成したGoogle Cloud Storage接続を選択します。
3. 「Replicatパラメータ」ページで、デフォルトのままにします。
4. プロパティ・ファイル・ページで、gg.eventhandler.gcs.bucketMappingTemplate=<gcs bucket>を検索し、<gcs bucket>をバケットの名前に置き換えます。バケットがない場合は、OCI GoldenGateによってバケットが作成されます。
5. 「作成および実行」を選択します。

タスク5: HeatWaveからGoogle Cloud Storageへのデータ・レプリケーションの検証

ソースHeatWaveデータベースの更新を実行して、Google Cloud Storageへのレプリケーションを確認します。

OCI Bastionで、MySQL IPおよびport 3306を使用してSSHポート番号転送セッションを作成します。公開SSHキーを追加します。
秘密キーおよびport 3306を使用して、クラウド・シェルでMySQLに接続します。
接続に成功したら、次のコマンドを実行します:
```
mysqlsh admin@localhost:3306 --sql
```

次のスクリプトを実行して、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;

ソースMySQLデプロイメント・コンソールで、変更データ取得Extract名(ECDC)を選択し、「統計」を選択します。SRC_OCIGGLL.SRC_CITYに10の挿入があることを確認します。
ターゲットのビッグ・データ・デプロイメント・コンソールで、Replicat名を選択し、「統計」を選択します。SRC_OCIGGLL.SRC_CITYに10の挿入があることを確認します。
Amazon Kinesisでは、ターゲット・データ・ストリーム/データ・ビューアでメッセージを確認できます。