スノーフレーク用のReplicatの追加

OCI GoldenGateデータ・レプリケーションにスノーフレーク・ターゲットのReplicatプロセスを追加する方法について学習します。

開始する前に

• ターゲット表がスノーフレーク・データベースに存在することを確認します。

• S3、ADLS Gen2またはGCSなどの外部ステージの場所を使用する場合は、Amazon Web Services、Google Cloud PlatformまたはAzureクラウド・アカウントを設定する必要があります。

• スノーフレークJDBCドライバ接続文字列

• スノーフレークへのレプリケーションに使用されるデータベース・ユーザーには、次の権限が付与されている必要があります。

  • ターゲット表に対するINSERT、UPDATE、DELETEおよびTRUNCATE。

  • スノーフレーク指定ステージおよび外部ステージのCREATEおよびDROP。

  • 外部ステージ(S3、ADLS、GCS)を使用する場合、外部表のCREATE、ALTERおよびDROP。

• Snowflakeの構成に関する考慮事項とベスト・プラクティスを確認してください

Replicatの追加(26ai)

このターゲット・タイプに固有の前提条件を確認してください。

1. OCI GoldenGateデプロイメント・コンソール・ナビゲーション・メニューで、「Replicat」を選択します。

2. Replicatページで、「Replicatの追加」を選択します。

3. 「Replicatの追加」パネルの「Replicat情報」ページで、必要に応じてフィールドに入力し、「次」を選択します。

   • Replicatタイプを選択します:

     • クラシックReplicat

     • 調整Replicat

   • 「プロセス名」に5文字以内で入力します。

   • このプロセスを他のプロセスと区別できるように、「摘要」を入力します。

4. Replicatオプション・ページで、必要に応じてフィールドに入力し、「次へ」を選択します。

   1. Replicat Trailの場合:

      • 「名前」を入力します。

      • トレイル・ファイルがデフォルト以外の場所にある場合は、サブディレクトリを入力します。

      • 暗号化プロファイルを選択します。暗号化プロファイルが作成されていない場合は、デフォルトでローカル・ウォレットが選択されます。

      • 「開始」で、データ処理の開始点を選択します:

        • ログでの位置(デフォルト)

        • Now

        • カスタム時間

   2. トレイル位置:

      • 「シーケンス番号」を入力します。

      • 「RBAオフセット」を入力します。

   3. 「ターゲット」で、ドロップダウンから「スノーフレーク」を選択し、次のいずれかを選択します。

      1. ストリーミング

      2. ステージングおよびマージを実行し、「使用可能なステージングの場所」を選択します。

   4. ターゲット資格証明の場合:

      • 「ドメイン」を選択します。

      • 指定したドメイン内の別名を選択します。

      • 「チェックポイント表」を選択します。デフォルトの選択を残すか、ターゲット・デプロイメント用に作成したチェックポイント表を選択します。

      • 「最大スレッド数」を選択します(調整Replicatのみ)。

5. 「管理対象オプション」ページで、必要に応じてオプション・フィールドに入力し、「次へ」を選択します。

   • プロファイル名がある場合は、そのプロファイル名を選択します。

   • デプロイメントのヘルスに不可欠を有効にします。

   • 自動開始設定を有効にして構成します。

6. 「パラメータ・ファイル」ページで、パラメータを追加してReplicatをさらに構成できます。たとえば:

   table source.table1;

   ノート:

   GoldenGateでは、デフォルトでグリニッジ標準時(GMT)が使用されます。Replicatのデフォルト設定をオーバーライドするには、SETENVを使用します。この変更はデプロイメントには適用されません。たとえば:

   setenv (TZ="US/Eastern")
   setenv (TZ="GMT+5")

7. (オプション)「プロパティ・ファイル」ページで、次のプロパティを確認します。

   • jvm.bootoptions: Replicat JVMにさらにメモリーを追加する必要がある場合は、-Xmx値を増やします(最大16 GBのメモリーを使用する場合は-Xmx16g、最大32 GBの場合は-Xmx32gなど)。

     ノート:スノーフレーク・ストリーミング・ハンドラに関連する既知の問題は、エラーException: java.lang.StackOverflowError thrown from the UncaughtExceptionHandler in thread "process reaper"で失敗します。この問題を回避するには、Replicatプロパティ・ファイルに次を追加します。

     jvm.bootoptions= -Djdk.lang.processReaperUseDefaultStackSize=true

   このターゲットのプロパティの詳細、およびステージ・ハンドラとマージ・ハンドラとストリーミング・ハンドラの違いについては、Oracle GoldenGate for Distributed Applications and Analyticsガイドのスノーフレークを参照してください。

8. 「作成および実行」を選択します。「作成」を選択した場合は、「Replicat」ページからReplicatを後で手動で起動できます。

Replicatの追加(21c)

Oracle GoldenGate 21cでスノーフレークのReplicatを追加するには:

1. OCI GoldenGateデプロイメント・コンソールの管理サービスの「概要」ページで、「Replicatの追加」(プラス・アイコン)を選択します。

2. 「Replicatの追加」ページで、Replicatタイプを選択し、「次」を選択します。

   Replicatのタイプは:

   • クラシックReplicat

   • 調整Replicat

3. 「Replicatオプション」ページで、次のフィールドに値を入力し、「次」を選択します。

   1. 「プロセス名」に、Replicatプロセスの名前を入力します。

   2. 「トレイル名」に、2文字のトレイル名を入力します。

   3. 「ターゲット」で、ドロップダウンからターゲットの「スノーフレーク」接続を選択します。

   4. 「使用可能な別名」で、ドロップダウンから別名を選択します。

   5. (オプション)外部ストレージの有効化: ドロップダウンから使用可能なステージングの場所を選択します。

4. 「Replicatパラメータ」ページで、必要なマッピングを追加し、「次へ」を選択します。

   ノート:

   • 調整Replicatを使用する場合は、パラメータ・ファイルの2行目に次のパラメータを追加します。

   TARGETDB LIBFILE libggjava.so SET property=/u02/Deployment/etc/conf/ogg/.properties

   調整Replicatを使用すると、複数のファイルが作成されます。省略すると、次のエラーが発生します。

   OGG-01091 Oracle GoldenGate Delivery, RSNOW.prm: Unable to open file "/u02/Deployment/etc/conf/ogg/001.properties" (error 2, No such file or directory).

   • スノーフレークで長時間実行されているマージ操作があり、多数のロックが監視されている場合は、他の表が同じ表を変更していないことを確認してください。また、表ロックの数が多い可能性があるため、調整Replicatを慎重に使用してください。

   • GoldenGateでは、デフォルトでグリニッジ標準時(GMT)が使用されます。Replicatのデフォルト設定をオーバーライドするには、SETENVを使用します。この変更はデプロイメントには適用されません。たとえば:

   setenv (TZ="US/Eastern")
   setenv (TZ="GMT+5")

   SETENVについてさらに学習します。

5. (オプション)「プロパティ・ファイル」ページで、次のプロパティを確認します。

   ノート:これらのプロパティは、接続の作成時に設定されるため、ここでは変更しないでください。

   • ggs.eventhandler.snowflake.connectionURL: スノーフレークに接続するためのJDBC URL。

   • ggs.eventhandler.snowflake.UserName: スノーフレーク・データベースのユーザー名。

   • ggs.eventhandler.snowflake.Password: スノーフレーク・データベース・ユーザーに関連付けられたパスワード。

   • ggs.eventhandler.snowflake.storageIntegration: スノーフレーク・データ・ウェアハウスでそれぞれのオブジェクト・ストア・ファイルにアクセスするための資格証明です。詳細は、Snowflake Storage Integrationを参照してください。

   • jvm.bootoptions: Replicat JVMにさらにメモリーを追加する必要がある場合は、-Xmx値を増やします(最大16 GBのメモリーを使用する場合は-Xmx16g、最大32 GBの場合は-Xmx32gなど)。

6. 「作成および実行」を選択します。「作成」を選択すると、後で管理サービスの「概要」ページからReplicatを手動で起動できます。

管理サービスの「概要」ページに戻り、Replicatプロセスの作成を表示したり、Replicatアクションにアクセスできます。

関連内容

• スノーフレーク・ターゲットの詳細

既知問題

バグ37518857: OGGDAA GGSスノーフレーク・ストリーミングReplicatエラー

Snowflakeストリーミング・ハンドラがException: java.lang.StackOverflowError thrown from the UncaughtExceptionHandler in thread "process reaper"で失敗する

回避策: Replicatプロパティ・ファイルに次を追加します。

jvm.bootoptions= -Djdk.lang.processReaperUseDefaultStackSize=true