ModifyDtsJobConfig 操作を呼び出して Data Transmission Service (DTS) タスクのパラメーターを変更する場合、`Parameters` パラメーターを設定する必要があります。
パラメーターの説明
`Parameters` パラメーターは JSON フォーマットの文字列です。パラメーターを変更するには、次のフィールドを指定します:
module
パラメーターが属するモジュール。有効値:
03:データ移行タスクまたは同期タスクの 完全データ移行 モジュール。
04:データ移行タスクの 増分書き込み モジュール。
07:データ同期タスクの 増分書き込み モジュール。
60:Kafka-to-Kafka および SLS-to-ClickHouse タスクの同期モジュール。
name
パラメーター名。詳細については、次の表をご参照ください。
value
パラメーター値。詳細については、次の表をご参照ください。
パラメーター (name) | 設定可能なモジュール (module) | 説明 (value) |
source.column.encoding | 03、04、または 07 | ソース Oracle データベースに書き込まれるビジネスデータの文字コード。このパラメーターは、データベースの文字セットとビジネスデータの文字セットに互換性がない場合に発生する可能性のある文字化けを防ぐために使用します。有効値:
|
sink.worker.type | 03 | `sink.worker.type` および `sink.bulk.copy.enable` パラメーターを使用して、MySQL または PostgreSQL データベースのデータ書き込みモードを設定します。
|
sink.bulk.copy.enable | 03 | |
sink.batch.size.minimum | 03 | 1 つの書き込みスレッドが 1 つのバッチでターゲットデータベースに書き込むレコードの最小数。値は 0 から 1,024 までの整数である必要があります。 |
sink.batch.size.maximum | 03、04、または 07 |
値は 0 から 1,024 までの整数である必要があります。 |
source.connection.idle.second | 03、04、または 07 | ソースデータベースへの再接続のタイムアウト期間。DTS がタイムアウト期間内にソースデータベースに再接続した場合、タスクは自動的に再開されます。そうでない場合、タスクは失敗します。値は 0 から 86,400 までの整数である必要があります。単位:秒。 |
sink.connection.idle.second | 03、04、または 07 | ターゲットデータベースへの再接続のタイムアウト期間。DTS がタイムアウト期間内にターゲットデータベースに再接続した場合、タスクは自動的に再開されます。そうでない場合、タスクは失敗します。値は 0 から 86,400 までの整数である必要があります。単位:秒。 |
trans.hot.merge.enable | 04 または 07 | ホットスポットマージを有効にするかどうかを指定します。有効値:
|
sink.batch.enable | 4、7 | データをバッチで送信するかどうかを指定します。有効値:
|
source.filter.ddl.enable | 04 および 07 | DDL 文をフィルターするかどうかを指定します。有効値:
|
sink.ignore.failed.ddl | 04、07 | 実行に失敗した DDL 文を無視するかどうかを指定します。有効値:
|
trans.size.maximum | 04、07 | トランザクション分割のしきい値。値は 0 から 1,024 までの整数である必要があります。 |
dts.datamove.record.spouter.writers | 07 | データ書き込みスレッドの数。値は 0 から 64 までの整数である必要があります。 |
selectdb.reservoir.group.by.target.schema | 04 または 07 | 書き込み時にターゲットテーブル名でデータをバッチ処理するかどうかを指定します。有効値:
|
selectdb.reservoir.timeout.milliseconds | 04 または 07 | 1 回のデータ書き込みのバッチ処理時間 (ミリ秒単位)。
|
sink.task.number | 03、04、07、または 60 | ターゲットデータベースにデータを書き込むスレッドの数。この値を増やすと、ホットスポットのないシナリオで書き込みパフォーマンスを向上させることができますが、ターゲットデータベースの負荷も増加します。
|
例
次の例は、JSON フォーマットのパラメーターを示しています:
[
{
"module": "07",
"name": "sink.connection.idle.second",
"value": 60
},
{
"module": "07",
"name": "sink.batch.size.maximum",
"value": 64
}
]