DataWorks:CreateDIJob

データソースの名前。

データソースの名前。

オフライン同期に使用される Data Integration リソースグループのコンピュートユニット (CU) 数。

オフライン同期に使用される Data Integration リソースグループの名前。

リアルタイム同期に使用される Data Integration リソースグループの CU 数。

リアルタイム同期に使用される Data Integration リソースグループの名前。

オフライン同期ノードに使用されるスケジューリングリソースグループの CU 数。

オフライン同期ノードに使用されるスケジューリングリソースグループの名前。

操作タイプ。有効な値:

• DefinePrimaryKey: プライマリキーを定義します。

• Rename: オブジェクトの名前を変更します。

• AddColumn: 列を追加します。

• HandleDml: DML 操作を処理します。

• DefineIncrementalCondition: 増分条件を定義します。

• DefineCycleScheduleSettings: サイクルスケジューリング設定を定義します。

• DefinePartitionKey: パーティションキーを定義します。

JSON 文字列フォーマットのルール式。

1. 名前変更ルール (Rename)

• 例: {"expression":"${srcDatasourceName}_${srcDatabaseName}_0922" }

• expression: 名前変更変換ルール式。式では次の変数がサポートされています: ${srcDatasourceName} (ソースデータソース名)、${srcDatabaseName} (ソースデータベース名)、${srcTableName} (ソーステーブル名)。

2. 列追加ルール (AddColumn)

• 例: {"columns":[{"columnName":"my_add_column","columnValueType":"Constant","columnValue":"123"}]}

• 指定しない場合、デフォルトのルールは列の追加もレプリケーションも実行しません。

• columnName: 追加列の名前。

• columnValueType: 追加列の値のタイプ。有効な値: Constant、Variable。

• columnValue: 追加列の値。columnValueType が Constant に設定されている場合、値は String 型のカスタム定数です。columnValueType が Variable に設定されている場合、値は組み込み変数です。有効な組み込み変数: EXECUTE_TIME (実行時間、Long 型)、DB_NAME_SRC (ソースデータベース名、String 型)、DATASOURCE_NAME_SRC (ソースデータソース名、String 型)、TABLE_NAME_SRC (ソーステーブル名、String 型)、DB_NAME_DEST (ターゲットデータベース名、String 型)、DATASOURCE_NAME_DEST (送信先データソース名、String 型)、TABLE_NAME_DEST (送信先テーブル名、String 型)、DB_NAME_SRC_TRANSED (変換後のデータベース名、String 型)。

3. 送信先テーブルのプライマリキー列の定義 (DefinePrimaryKey)

• 例: {"columns":["ukcolumn1","ukcolumn2"]}

• 指定しない場合、デフォルトでソースのプライマリキー列が使用されます。

• 送信先テーブルが既に存在する場合: Data Integration システムは送信先テーブルスキーマを変更しません。指定されたプライマリキー列が送信先の列セットにない場合、ノードは起動時にエラーを報告します。

• 送信先テーブルが自動作成を使用する場合: Data Integration システムは送信先テーブルスキーマを自動的に作成し、定義されたプライマリキー列を含めます。指定されたプライマリキー列が送信先の列セットにない場合、ノードは起動時にエラーを報告します。

4. DML 操作処理ルール (HandleDml)

• 例: {"dmlPolicies":[{"dmlType":"Delete","dmlAction":"Filter","filterCondition":"id > 1"}]}

• 指定しない場合、デフォルトのルールは Insert、Update、Delete に対して Normal です。

• dmlType: DML 操作タイプ。有効な値: Insert、Update、Delete。

• dmlAction: DML 操作処理ポリシー。有効な値: Normal (通常処理)、Ignore (無視)、Filter (条件付き通常処理、dmlType が Update または Delete の場合に使用)、LogicalDelete (論理削除)。

• filterCondition: DML フィルター条件。dmlAction が Filter に設定されている場合に使用します。

5. 増分条件 (DefineIncrementalCondition)

• 例: {"where":"id > 0"}

• 増分フィルター条件を指定します。

6. サイクルスケジューリングパラメーター (DefineCycleScheduleSettings)

• 例: {"cronExpress":" * * * * * *", "cycleType":"1"}

• サイクルノードスケジューリングパラメーターを指定します。

7. パーティションキーの定義 (DefinePartitionKey)

• 例: {"columns":["id"]}

• パーティションキーを指定します。

ルール名。操作タイプとターゲットタイプが同じ場合、ルール名は一意である必要があります。名前の長さは 50 文字を超えることはできません。

操作が適用されるターゲットタイプ。有効な値:

• Table

• Schema

• Database

サイクルスケジューリングが必要な同期タイプ。有効な値:

• Full: フル同期。

• OfflineIncremental: オフライン増分同期。

スケジューリングパラメーター。