レプリケーション ジョブにランタイム引数を渡す

このページでは、Cloud Data Fusion レプリケーション ジョブでランタイム引数を渡す方法について説明します。

レプリケーション ジョブに Debezium 引数を渡す

Cloud Data Fusion の MySQL または SQL Server レプリケーション ジョブに Debezium 引数を渡すには、source.connector という接頭辞を持つランタイム引数を指定します。

コンソール

  1. インスタンスに移動します:

    1. Google Cloud コンソールで、Cloud Data Fusion のページに移動します。

    2. Cloud Data Fusion ウェブ インターフェースでインスタンスを開くには、[Instances] をクリックしてから、[View instance] をクリックします。

      [インスタンス] に移動

  2. [ メニュー] > [コントロール センター] をクリックします。

  3. レプリケーション ジョブの [アプリケーション] を見つけて、 [設定] をクリックします。[設定] ウィンドウが開きます。

  4. [キー] フィールドに、接頭辞 source.connector を付けてレプリケーション ジョブのランタイム引数を指定します。

    [設定] に移動し、source.connector をキーの接頭辞として入力します。

  5. [保存して閉じる] をクリックします。

REST API

REST API を使用してランタイム引数を設定するには、CDAP 設定マイクロサービスのリファレンスをご覧ください。

JDBC パラメータを構成する

MySQL または SQL Server のレプリケーション ジョブに JDBC パラメータを渡すには、source.connector.database という接頭辞のランタイム引数を指定します。

たとえば、JDBC パラメータ sessionVariables を MAX_EXECUTION_TIME=43200000 に構成するには、キー source.connector.database.sessionVariables と値 MAX_EXECUTION_TIME=43200000 で ランタイム引数を設定します。

複数の JDBC パラメータを構成するには、パラメータごとにランタイム引数を設定します。たとえば、JDBC パラメータ encrypt=true&trustServerCertificate=true を構成するには、次の引数を渡します。

キー 値
source.connector.database.encrypt true
source.connector.database.trustServerCertificate true

プライマリキーパラメータを構成する

複製されるソーステーブルには、主キーが必要です。これは、Oracle がソース データベースである場合にのみ、厳密な要件となります。SQL Server ソースと MySQL ソースの場合、ソーステーブルにキーがない場合でも、カスタム主キーを指定できます。

次のランタイム引数を使用して、key パラメータを設定します。

source.connector.message.key.columns = SCHEMA.TABLE:KEY_COLUMN

以下を置き換えます。

  • SCHEMA: ソーススキーマの名前。
  • TABLE: ソーステーブル名。
  • KEY_COLUMN: セキュアキーを含む列。

key プロパティを使用して、複数のテーブルの主キーを設定できます。次の例では、テーブル inventory.customers と purchase.orders のキーを設定する方法を示します。

source.connector.message.key.columns = inventory.customers:pk1,pk2;purchase.orders:pk3,pk4

[設定] に移動し、主キー パラメータを設定します。

SQL Server レプリケーションでスナップショットの分離モードを構成する

分離モードのランタイム引数の詳細については、SQL Server レプリケーションの分離レベルをご覧ください。

次のステップ