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

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

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

Debezium アプリケーションから Cloud Data Fusion の MySQL または SQL Server レプリケーション ジョブに引数を渡すには、接頭辞 source.connector を使用してランタイム引数を指定します。

Console

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

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

    2. Cloud Data Fusion Studio でインスタンスを開くには、[インスタンス]、[インスタンスを表示] の順にクリックします。

      [インスタンス] に移動

  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 レプリケーションの分離レベルをご覧ください。

次のステップ