HeatWaveからAutonomous Data Warehouseへのデータのレプリケート

始める前に

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

OCIバスチョン、HeatWaveへの接続、サンプル・データベースのロードおよび挿入の実行
ソース・データベースとして機能するHeatWaveデータベース
ターゲット・データベースとして機能するAutonomous Data Warehouseインスタンス

環境設定: HeatWave

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

サンプル・データ・スクリプトのダウンロード。次に、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コンソールで、HeatWaveデータベースが使用するサブネットを見つけます。
2. サブネットのセキュリティ・リストで、port TCP/3306のイングレス・ルールを作成します。
「ターゲット・スキーマ・スクリプトのダウンロード」、Autonomous Data Warehouseインスタンスのスクリプトを実行して、スキーマおよび表を作成します。 Autonomous Data Warehouse DatabaseアクションSQLツールを使用して、スクリプトを実行できます:
1. 「Oracle Cloudコンソール」で、Autonomous Data Warehouseデータベースの詳細ページを開き、「データベース・アクション」をクリックします。
2. データベース・アクションの「開発」で、SQLをクリックします。
3. SQLツールで、OCIGGLL_OCIGGS_SETUP_USERS_ADW.sqlからSQLワークシートにスクリプトをコピーして貼り付け、「スクリプトの実行」をクリックします。成功すると、「スクリプトの出力」タブに確認メッセージが表示されます。
4. SQLワークシートをクリアし、OCIGGLL_OCIGGS_SRC_MIRROR_USER_SEED_DATA.sqlから表の作成スクリプトのみをコピーして貼り付けます。データは後のタスクにロードされます。
  
  ヒント:
  SQLツールでスクリプトを正常に実行するには、表の作成文を個別に実行する必要がある場合があります。
5. 表が正常に作成されたことを確認するには、SQLウィンドウを閉じて再度開きます。ナビゲータ・タブで、SRC_OCIGGLLスキーマを探し、それぞれのドロップダウンから表を選択します。

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

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

ソースHeatWaveデータベースに「デプロイメントを作成」します。
ターゲットAutonomous Data Warehouseにデプロイメントを作成します。
ソースHeatWaveデータベースへの接続の作成。
ターゲットAutonomous Data Warehouseの接続の作成。
GoldenGateへの接続を作成し、次にこの接続をソースMySQLデプロイメントに割り当てます。
ソース接続をソースのMySQLデプロイメントに割り当てます。
ターゲット接続をターゲットOracleデプロイメントに割り当てます。

タスク2: 抽出の作成

「デプロイメント」ページで、タスク1で作成したMySQLデプロイメントを選択します。
デプロイメントの詳細ページで、「コンソールの起動」をクリックします。
タスク1でデプロイメントを作成したときに指定した管理者資格証明を使用して、ソースのMySQLデプロイメント・コンソールにサインインします。
ナビゲーション・メニューで、「DB接続」を選択します。
HeatWave接続の資格証明を確認します。ドメインと別名を書き留めます。
変更データ取得抽出を追加して実行と次の値:
- 「抽出」タイプで、「変更データ取得」を選択します。
- 「プロセス名」に、「抽出」プロセスの名前を入力します。
- 「ドメイン」で、ドメインを選択します。
- 「別名」で、別名を選択します。
- 「抽出」トレイル名に、証跡ファイルの名前を入力します。
- 「パラメータ・ファイル」ページで、次を追加します:
```
TABLE SRC_OCIGGLL.*;
```
初期ロードExtractの追加および実行と次の値:
- 「抽出」タイプで、「初期ロード抽出」を選択します。
- 「プロセス名」に、名前を入力します。
- 「パラメータ・ファイル」ページで、次を追加します:
```
TABLE SRC_OCIGGLL.*;
```

タスク3: 「初期ロード抽出」の「分散パス」を作成

デプロイメント・ページで、ターゲットのAutonomous Databaseデプロイメントを選択します。
デプロイメントの詳細ページで、「コンソールを起動」をクリックし、管理者ユーザーとしてログインします。
IAM資格証明ストアを使用している場合は、「分散パス」の作成ステップに進みます。 GoldenGate資格証明ストアを使用する場合は、ソースGoldenGateがターゲットGoldenGateへの接続に使用するユーザーを作成します。
1. ナビゲーション・メニューで、「ユーザー管理」をクリックします。
2. 新しいユーザーを追加 (プラス・アイコン)をクリックし、次のようにフィールドに入力して、送信をクリックします:
  - 「ユーザー名」には、ggsnetと入力します。
  - 「ロール」で、「オペレータ」を選択します。
  - 確認のためにパスワードを2回入力します。
「ソース」 PostgreSQLデプロイメント・コンソールで、前のステップで作成したユーザーのパス接続を作成します。
1. ナビゲーション・メニューで、「パス接続」をクリックします。
2. パス接続の追加 (プラス・アイコン)をクリックし、次のようにフィールドに入力して、送信をクリックします:
  - 資格証明別名に、dpuserと入力します。
  - ユーザーIDに、ggsnetと入力
  - Passwordに、前のステップで使用したものと同じパスワードを入力します。
「分散パス」を作成します。
1. サービス・メニュー・バーで、「分散サービス」をクリックし、「分散パスの追加」 (プラス・アイコン)をクリックします。
2. 次のように「パスの追加」フォームに入力します:
  - 「パスの情報」ページで、次の手順を実行します:
    1. 「パス名」には、このパスの名前を入力します。
    2. 「次へ」をクリックします。
  - 「ソース・オプション」ページで、次の手順を実行します:
    1. ソース「抽出」では、空白のままにします。
    2. 「トレイル名」に、「初期ロード抽出」証跡名(I1)を入力します。
    3. 「次へ」をクリックします。
  - 「ターゲット・オプション」ページで、次の手順を実行します:
    1. 「ターゲット」で、wssを選択します。
    2. 「ターゲット・ホスト」に、ターゲット・デプロイメントURLをhttps://または末尾のスラッシュなしで入力します。
    3. 「ポート番号」には、443と入力します。
    4. 「トレイル名」には、I1と入力します。
    5. 「ターゲット認証メソッド」で、「UserID別名」を選択します。
    6. 「ドメイン」には、前のステップで作成したドメイン名を入力します。
    7. 「別名」に、前のステップ(dpuser)で作成した別名を入力します。
    8. 「次へ」をクリックします。
3. 「Create and Run」をクリックします
「分散サービス」ページに戻り、作成したパスを確認できます。
分散パスを確認します:
1. 「受信サービス」をクリックします。
2. 「分散パス」の詳細を確認します。

タスク4: 「初期ロード抽出」にReplicatを追加

ターゲット「OCI GoldenGateデプロイメント・コンソール」に、チェックポイント表を追加します。
1. ナビゲーション・メニューを開き、「DB接続」をクリックします。
2. 「データベースに接続SourceATP」をクリックします。
3. ナビゲーション・メニューで、「チェックポイント」をクリックします。
4. 「チェックポイント」ページで、「チェックポイントの追加」 (プラス・アイコン)をクリックします。
5. 「チェックポイント表」には、SRCMIRROR_OCIGGLL.CHECKTABLEと入力します。
6. 「送信」をクリックします。
  
  ヒント:
  発行時に画面はリフレッシュされません。チェックポイント表が追加されたことを確認するには、検索フィールドにSRCMIRROR_OCIGGLL.CHECKTABLEと入力し、「検索」をクリックします。
Replicatを追加します:
1. 「管理者サービス」をクリックし、Replicatの追加 (プラス・アイコン)をクリックします。
2. 「Replicatの追加」ページで、次のフォーム・フィールドに入力し、「次」をクリックします。
  - Replicatタイプで、「非統合Replicat」を選択します。
  - 「プロセス名」には、RILなどの名前を入力します。
3. Replicatオプション・ページで、次のフォーム・フィールドに入力し、次をクリックします:
  - 「名前」に、タスク2からのトレイルの名前を入力します( I1)。
  - 「ドメイン」で、Autonomous Database接続のドメインを選択します。
  - 「別名」で、Autonomous Database接続の別名を選択します。
  - 「チェックポイント表」で、ステップ1で作成したチェックポイント表を選択します。
4. 「管理オプション」ページで、フィールドはそのままにして、「次」をクリックします。
5. Replicatパラメータ・ページで、次のマッピングを追加し、作成して実行をクリックします:
```
MAP SRC_OCIGGLL.*, TARGET SRCMIRROR_OCIGGLL.*;
```
「概要」ページに戻り、Replicatの詳細を確認できます。
Replicat ( RIL)を選択し、その「詳細」を表示します。
「統計」をクリックして、挿入の数を確認します。ページをリフレッシュしてください。
- 挿入の数が変更されない場合は、「初期ロード」のすべてのレコードがロードされ、Replicat ( RIL)を停止できます
- 挿入の数が増え続ける場合は、初期ロード・レコードがすべてロードされるまでページをリフレッシュしてから続行してください。

タスク5: 初期ロードの確認

「Oracle Cloudコンソール」で、Autonomous Data Warehouseデータベースの詳細ページから「データベース・アクション」を開きます。
データベース・アクションの「開発」で、SQLをクリックします。
SQLツールで、次の各文をワークシートに入力し、文の実行をクリックします:
```
SELECT * FROM SRCMIRROR_OCIGGLL.SRC_CITY;
SELECT * FROM SRCMIRROR_OCIGGLL.SRC_CUSTOMER;
```

出力では、初期ロードの結果としてターゲット・データベース表にロードされたデータが返されます。

タスク6: 「変更データ取得」の「分散パス」の作成

ソース・デプロイメント・コンソールで、「分散サービス」をクリックします。
「分散パス」の追加をクリックします。
次のように「パスの追加」フォームに入力します:
1. 「パスの情報」ページで、次の手順を実行します:
  1. 「パス名」に、名前を入力します。
  2. 「次へ」をクリックします。
2. 「ソース・オプション」ページで、次の手順を実行します:
  1. ソース「抽出」で、「変更データ取得抽出」 (ECDC))を選択します。
  2. 「トレイル名」で、「変更データ取得」証跡ファイル(C1)を選択します。
  3. 「次へ」をクリックします。
3. 「ターゲット・オプション」ページで、次の手順を実行します:
  1. 「ターゲット」で、wssを選択します。
  2. 「ターゲット・ホスト」に、ターゲット・デプロイメント・コンソールのURLを入力します(これは、デプロイメントの詳細ページで、https://または末尾のスラッシュを使用せずに確認できます)。
  3. 「ポート番号」には、443と入力します。
  4. 「トレイル名」には、C1と入力します。
  5. 「ターゲット認証メソッド」で、「UserID別名」を選択します。
  6. 「ドメイン」に、ドメイン名を入力します。
  7. 「別名」に、別名を入力します。
4. 「パスの作成および実行」をクリックします。
ターゲット・デプロイメント・コンソールで、「受信サービス」をクリックし、作成した「受信パス」を確認します。

タスク7: 「変更データ取得」にReplicatを追加

Replicatに次の値を追加します:
1. Replicatの「情報」ページで:
  - Replicatタイプで、「調整Replicat」を選択します。
  - 「プロセス名」には、RCDCなどの名前を入力します。
2. Replicatオプション・ページで、次の手順を実行します:
  - Replicatトレイルに、タスク2からのトレイルの名前を入力します( C1)。
  - 「ドメイン」で、Autonomous Database接続のドメインを選択します。
  - 「別名」に、資格証明別名を入力します。
  - 「チェックポイント表」で、作成したチェックポイント表を選択します。
3. Replicatパラメータ・ページで、次のマッピングを追加し、作成して実行をクリックします:
```
MAP SRC_OCIGGLL.*, TARGET SRCMIRROR_OCIGGLL.*;
```
「管理サービス」の「概要」ページで、「初期ロード」のReplicat (RIL)を選択し、その「詳細」を表示します。
「統計」をクリックして、挿入の数を確認します。ページをリフレッシュしてください。
- 挿入の数が変更されない場合は、初期ロードのすべてのレコードがロードされ、Replicat (RIL)を停止できます
- 挿入の数が増え続ける場合は、初期ロード・レコードがすべてロードされるまでページをリフレッシュしてから続行してください。
「管理サービスの概要」ページに戻り、「調整Replicat」 (RCDC)を起動します。
「調整Replicat」を起動した後、その「詳細」および「統計」を確認して、挿入の数を表示します。

タスク8: 「変更データ取得」の検証

ソースのHeatWaveデータベースに対する更新を実行して、Autonomous Data Warehouseへのレプリケーションを確認します。

OCI Bastionで、MySQL IPおよびポート3306を使用してSSHポート転送セッションを作成します。公開SSHキーを追加します。
秘密キーとポート3306を使用して、Cloud Shellの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デプロイメント・コンソールで、「変更データ取得抽出」名を選択し、「統計」をクリックします。 SRC_OCIGGLL.SRC_CITYに10個の挿入があることを確認します。

ノート:
「抽出」が挿入を取得しなかった場合は、「抽出」を再起動します。