Saat memanggil operasi ModifyDtsJobConfig untuk mengubah parameter task Data Transmission Service (DTS), Anda harus mengonfigurasi parameter Parameters.
Deskripsi Parameter
Parameter Parameters berupa string dalam format JSON. Untuk mengubah suatu parameter, tentukan bidang-bidang berikut:
module
Modul tempat parameter tersebut berada. Nilai yang valid:
03: Modul Full Data Migration untuk task migrasi atau sinkronisasi data.
04: Modul Incremental Write untuk task migrasi data.
07: Modul Incremental Write untuk task sinkronisasi data.
60: Modul sinkronisasi untuk task Kafka-to-Kafka dan SLS-to-ClickHouse.
name
Nama parameter. Untuk informasi lebih lanjut, lihat tabel berikut.
value
Nilai parameter. Untuk informasi lebih lanjut, lihat tabel berikut.
Parameter (name) | Modul yang dapat dikonfigurasi (module) | Deskripsi (value) |
source.column.encoding | 03, 04, atau 07 | Pengkodean karakter dari data bisnis yang ditulis ke database Oracle sumber. Gunakan parameter ini untuk mencegah teks menjadi rusak (garbled) yang dapat terjadi ketika set karakter database tidak kompatibel dengan set karakter data bisnis. Nilai yang valid:
|
sink.worker.type | 03 | Gunakan parameter sink.worker.type dan sink.bulk.copy.enable untuk mengonfigurasi mode penulisan data ke database MySQL atau PostgreSQL.
|
sink.bulk.copy.enable | 03 | |
sink.batch.size.minimum | 03 | Jumlah minimum catatan yang ditulis oleh thread penulisan ke database tujuan dalam satu batch. Nilainya harus berupa bilangan bulat dari 0 hingga 1.024. |
sink.batch.size.maximum | 03, 04, atau 07 |
Nilainya harus berupa bilangan bulat dari 0 hingga 1.024. |
source.connection.idle.second | 03, 04, atau 07 | Periode timeout untuk menyambung ulang ke database sumber. Jika DTS berhasil menyambung ulang ke database sumber dalam periode timeout tersebut, task akan dilanjutkan secara otomatis. Jika tidak, task gagal. Nilainya harus berupa bilangan bulat dari 0 hingga 86.400. Satuan: detik. |
sink.connection.idle.second | 03, 04, atau 07 | Periode timeout untuk menyambung ulang ke database tujuan. Jika DTS berhasil menyambung ulang ke database tujuan dalam periode timeout tersebut, task akan dilanjutkan secara otomatis. Jika tidak, task gagal. Nilainya harus berupa bilangan bulat dari 0 hingga 86.400. Satuan: detik. |
trans.hot.merge.enable | 04 atau 07 | Menentukan apakah penggabungan hot spot diaktifkan. Nilai yang valid:
|
sink.batch.enable | 4, 7 | Menentukan apakah data dikirim dalam batch. Nilai yang valid:
|
source.filter.ddl.enable | 04 dan 07 | Menentukan apakah pernyataan DDL difilter. Nilai yang valid:
|
sink.ignore.failed.ddl | 04, 07 | Menentukan apakah pernyataan DDL yang gagal dieksekusi diabaikan. Nilai yang valid:
|
trans.size.maximum | 04, 07 | Ambang batas untuk pemisahan transaksi. Nilainya harus berupa bilangan bulat dari 0 hingga 1.024. |
dts.datamove.record.spouter.writers | 07 | Jumlah thread penulisan data. Nilainya harus berupa bilangan bulat dari 0 hingga 64. |
selectdb.reservoir.group.by.target.schema | 04 atau 07 | Menentukan apakah data dikelompokkan berdasarkan nama tabel tujuan saat penulisan. Nilai yang valid:
|
selectdb.reservoir.timeout.milliseconds | 04 atau 07 | Waktu batching untuk satu penulisan data, dalam milidetik.
|
sink.task.number | 03, 04, 07, atau 60 | Jumlah thread untuk menulis data ke database tujuan. Meningkatkan nilai ini dapat meningkatkan performa penulisan pada skenario tanpa hot spot, tetapi juga meningkatkan beban pada database tujuan.
|
Contoh
Contoh berikut menunjukkan parameter dalam format JSON:
[
{
"module": "07",
"name": "sink.connection.idle.second",
"value": 60
},
{
"module": "07",
"name": "sink.batch.size.maximum",
"value": 64
}
]