すべてのプロダクト
Search
ドキュメントセンター

Data Transmission Service:パラメーター

最終更新日:Dec 11, 2025

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 データベースに書き込まれるビジネスデータの文字コード。このパラメーターは、データベースの文字セットとビジネスデータの文字セットに互換性がない場合に発生する可能性のある文字化けを防ぐために使用します。有効値:

  • default

  • GB 2312

  • GBK

  • GB 18030

  • UTF-8

  • UTF-16

  • UTF-32

sink.worker.type

03

`sink.worker.type` および `sink.bulk.copy.enable` パラメーターを使用して、MySQL または PostgreSQL データベースのデータ書き込みモードを設定します。

  • バルクコピーモードを使用するには、`sink.worker.type` を `stream` に、`sink.bulk.copy.enable` を `true` に設定します。

  • PreparedStatement executeBatch モードを使用するには、`sink.worker.type` を `batch` に、`sink.bulk.copy.enable` を `false` に設定します。

sink.bulk.copy.enable

03

sink.batch.size.minimum

03

1 つの書き込みスレッドが 1 つのバッチでターゲットデータベースに書き込むレコードの最小数。値は 0 から 1,024 までの整数である必要があります。

sink.batch.size.maximum

03、04、または 07

  • 完全データ移行 モジュール:1 つの書き込みスレッドが 1 つのバッチでターゲットデータベースに書き込むレコードの最大数。

  • 増分書き込み モジュール:マージするトランザクション数。

値は 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

ホットスポットマージを有効にするかどうかを指定します。有効値:

  • true:ホットスポットマージを有効にします。

  • false:ホットスポットマージを無効にします。

sink.batch.enable

4、7

データをバッチで送信するかどうかを指定します。有効値:

  • true:データをバッチで送信します。

  • false:データをバッチで送信しません。

source.filter.ddl.enable

04 および 07

DDL 文をフィルターするかどうかを指定します。有効値:

  • true:増分タスクは DDL 文をフィルターして続行します。

  • false:増分タスクは DDL 文を正常に実行します。

sink.ignore.failed.ddl

04、07

実行に失敗した DDL 文を無視するかどうかを指定します。有効値:

  • true:DDL 文の実行に失敗した場合、タスクは失敗を無視して続行します。

  • false: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

書き込み時にターゲットテーブル名でデータをバッチ処理するかどうかを指定します。有効値:

  • true:はい。

  • false (デフォルト)

selectdb.reservoir.timeout.milliseconds

04 または 07

1 回のデータ書き込みのバッチ処理時間 (ミリ秒単位)。

  • 値の範囲:1000~10000。

  • デフォルト値:5000。

sink.task.number

03、04、07、または 60

ターゲットデータベースにデータを書き込むスレッドの数。この値を増やすと、ホットスポットのないシナリオで書き込みパフォーマンスを向上させることができますが、ターゲットデータベースの負荷も増加します。

  • 値の範囲:1~64。

  • デフォルト値:32

次の例は、JSON フォーマットのパラメーターを示しています:

[
    {
        "module": "07",
        "name": "sink.connection.idle.second",
        "value": 60
    },
    {
        "module": "07",
        "name": "sink.batch.size.maximum",
        "value": 64
    }
]