Autonomous AI Transaction ProcessingからMicrosoft Fabric Mirrorへのデータのレプリケート

このクイックスタートでは、OCI GoldenGateを使用して、Autonomous AI Transaction ProcessingからMicrosoft Fabric Mirrorにデータをレプリケートする方法を示します。

開始する前に

このクイックスタートを正常に完了するには:

  • ソースのAutonomous AI Transaction Processingインスタンス。
  • Microsoft Fabric Mirrorワークスペース:
    • Microsoft Entra ID Appの登録を作成します。アプリケーション(クライアント)ID、ディレクトリ(テナント)IDおよびクライアント・シークレットを書き留めます。
    • Fabric Workspaceに移動し、「アクセスの管理」をクリックして「ユーザーまたはグループの追加」をクリックします。登録済アプリケーション名を入力し、「コントリビュータ・ロール」を選択して「追加」をクリックします。
    • ワークスペースにミラー化されたデータベースを作成します。

環境設定: 自律型AIトランザクション処理

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

ソースのAutonomous AI Transaction Processingを設定するには:

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

このクイックスタートの例では、ソースとターゲットの両方のデプロイメントおよび接続が必要です。
  1. ソースのAutonomous AI Transaction ProcessingインスタンスのOracleデプロイメントを作成します
  2. ターゲットMicrosoft Fabric Mirrorビッグ・データ・デプロイメントを作成します
  3. ソースAutonomous AI Transaction Processingへの接続を作成します
  4. Microsoft Fabric Mirrorへの接続を作成します。
  5. GoldenGateへの接続を作成してから、ソースOracleデプロイメントにこの接続を割り当てます
  6. Autonomous AI Transaction Processing接続をソースOracleデプロイメントに割り当てます
  7. Microsoft Fabric Mirror接続をターゲット・ビッグ・データ・デプロイメントに割り当てます

タスク2: Extractの追加

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

タスク3: Distribution Pathを追加して実行します

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

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

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

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

  1. ターゲット・ビッグ・データ・デプロイメント・コンソールで、Administrator Serviceをクリックし、Add Replicat (プラス・アイコン)をクリックします。
  2. 次の値を使用してReplicatを追加します:
    1. Replicat情報ページのReplicatタイプで、Classic Replicatを選択し、プロセス名を入力して「次へ」をクリックします。
    2. 「レプリケーション・オプション」ページで、次の手順を実行します。
      • 「名前」に、タスク2からトレイルの名前を入力します。
      • 「ターゲット」で、「Microsoft Fabric Mirror」を選択します。
      • 「使用可能な別名」で、ドロップダウンからMicrosoft Fabric Mirror接続を選択します。
    3. 「Managed Options」ページで、デフォルトのままにします。
    4. Replicatの「パラメータ」ページで、デフォルトのままにします。
    5. Replicatプロパティ・ページで、次のプロパティを更新します。
      • gg.eventhandler.onelake.workspace=<target_workspace_name>
      • gg.eventhandler.onelake.mirror=<mirror-name>
  3. 「作成および実行」をクリックします。
「概要」ページに戻り、Replicatの詳細を確認できます。

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

ソースAutonomous Transaction Processingインスタンスを更新して、Microsoft Fabric Mirrorへのレプリケーションを確認します。
  1. Oracle Cloudコンソールで、ナビゲーション・メニューを開き、「Oracle Database」を選択し、次に「Autonomous Transaction Processing」を選択します。
  2. Autonomous Transaction Processingインスタンスのリストで、ソース・インスタンスを選択してその詳細を表示します。
  3. データベースの詳細ページで、「データベース・アクション」をクリックします。

    ノート:

    自動的にログインします。そうでない場合は、データベース資格証明を使用してログインします。
  4. データベース・アクションのホームページで、「SQL」を選択します。
  5. ワークシートに次を入力し、「スクリプトの実行」をクリックします。
    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. ターゲット・ビッグ・データのOCI GoldenGateデプロイメント・コンソールで、 Replicat名を選択し、「統計」をクリックします。SRC_OCIGGLL.SRC_CITYに10個の挿入があることを確認します。