Data Transmission Service:Deskripsi parameter Reserve

Parameter

Wajib

Deskripsi

targetTableMode

Ya

Mode pemrosesan untuk tabel yang sudah ada di database tujuan:

• 0: Menjalankan pemeriksaan awal dan melaporkan kesalahan untuk menghentikan tugas.

• 2: Mengabaikan error dan melanjutkan tugas.

dts.datamove.source.bps.max

Tidak

Jumlah maksimum data yang dapat disinkronkan atau dimigrasikan per detik untuk tugas penuh atau inkremental, dalam byte (B).

conflict

Tidak

Kebijakan resolusi konflik global untuk tugas sinkronisasi dua arah. Nilai yang valid:

• overwrite: Jika terjadi konflik data selama sinkronisasi, catatan yang bertentangan di database tujuan akan ditimpa.

• interrupt: Jika terjadi konflik data selama sinkronisasi, tugas sinkronisasi melaporkan error dan keluar. Tugas masuk ke status Gagal. Anda harus memperbaiki tugas secara manual.

• ignore: Jika terjadi konflik data selama sinkronisasi, pernyataan sinkronisasi saat ini dilewati dan tugas dilanjutkan. Catatan yang bertentangan di database tujuan digunakan.

filterDDL

Tidak

Menentukan apakah akan memfilter operasi DDL untuk tugas maju dalam sinkronisasi dua arah. Nilai yang valid:

• true: Tidak menyinkronkan operasi DDL.

• false: Menyinkronkan operasi DDL.

  Penting

  Tugas balik secara otomatis memfilter operasi DDL.

autoStartModulesAfterConfig

Tidak

Parameter kontrol startup tugas. Nilai yang valid:

• none: Setelah tugas DTS dikonfigurasi, modul seperti Pemeriksaan Awal tidak dijalankan. Anda harus menjalankan tugas secara manual.

• auto: Setelah tugas DTS dikonfigurasi, modul Pemeriksaan Awal dan semua modul berikutnya dijalankan secara otomatis.

  Catatan

  Nilai default adalah auto untuk skenario beli-dulu. Parameter ini tidak berlaku untuk skenario konfigurasi-dulu.

etlOperatorCtl

Tidak

Menentukan apakah akan mengonfigurasi fitur ekstrak, transformasi, dan muat (ETL). Nilai yang valid:

• Y: Ya, konfigurasikan fitur ETL.

• N: Tidak, jangan konfigurasikan fitur ETL.

etlOperatorSetting

Tidak

Pernyataan pemrosesan data untuk ETL. Untuk informasi selengkapnya, lihat Sintaks DSL pemrosesan data.

etlOperatorColumnReference

Tidak

Bidang khusus untuk layanan T+1. Ini adalah operator ETL.

configKeyMap

Tidak

Informasi konfigurasi untuk operator ETL.

syncArchitecture

Tidak

Topologi sinkronisasi. Nilai yang valid:

• oneway: sinkronisasi satu arah.

• bidirectional: sinkronisasi dua arah.

dataCheckConfigure

Tidak

Konfigurasi validasi data. Untuk detailnya, lihat Deskripsi parameter DataCheckConfigure.

dbListCaseChangeMode

Tidak

Kebijakan sensitivitas huruf besar/kecil untuk nama objek di database tujuan. Nilai yang valid:

• default: Menggunakan kebijakan default DTS.

• source: Mempertahankan huruf besar/kecil yang sama seperti database sumber.

• dest_upper: Mengikuti kebijakan default database tujuan (huruf besar).

• dest_lower: Mengikuti kebijakan default database tujuan (huruf kecil).

maxRetryTime

Tidak

Waktu tunggu sebelum mencoba kembali koneksi ke database sumber atau tujuan setelah terjadi pengecualian yang dapat diprediksi, seperti error jaringan atau lock wait. Nilainya harus bilangan bulat antara 600 hingga 86.400. Satuannya detik. Nilai default adalah 720 menit (43.200 detik). Atur nilai ini minimal 30 menit (1.800 detik).

retry.blind.seconds

Tidak

Waktu tunggu sebelum mencoba kembali setelah terjadi pengecualian tak terduga di database sumber atau tujuan, seperti pengecualian eksekusi DDL atau DML. Nilainya harus bilangan bulat antara 60 hingga 86.340. Satuannya detik. Nilai default adalah 10 menit (600 detik). Atur nilai ini minimal 10 menit (600 detik).

modulesExtraConfiguration

Tidak

Item konfigurasi tambahan untuk modul. Untuk informasi tentang parameter dalam item konfigurasi, lihat Deskripsi parameter Parameters.

Format: Array JSON

Contoh:

[
   {
   "module": "07",
   "name": "selectdb.reservoir.group.by.target.schema",
   "value": true
   }
]

Parameter

Wajib

Deskripsi

vpcId

Ya

ID virtual private cloud (VPC) tempat instans langganan berada.

vswitchId

Ya

ID virtual switch untuk instans langganan.

startTime

Tidak

Waktu mulai untuk langganan data, sebagai stempel waktu UNIX dalam detik.

endTime

Tidak

Waktu akhir untuk langganan data, sebagai stempel waktu UNIX dalam detik.

Parameter

Wajib

Deskripsi

srcInstanceId

Tidak

ID instans CEN untuk instans sumber. Contoh:

{
   "srcInstanceId": "cen-9kqshqum*******"  }

destInstanceId

Tidak

ID instans CEN untuk instans tujuan. Contoh:

{
   "destInstanceId": "cen-9kqshqum*******"  }

Parameter

Kondisi konfigurasi

Deskripsi

privilegeMigration

Berlaku ketika database sumber dan tujuan keduanya merupakan RDS for MySQL.

Menentukan apakah akan memigrasikan akun. Nilai yang valid:

• true: Migrasikan akun.

• false (default): Jangan migrasikan akun.

privilegeDbList

Informasi tentang akun migrasi. Untuk format parameternya, lihat Pratinjau parameter permintaan OpenAPI. Contoh:

[{\"user\":\"user1\",\"host\":\"%\",\"oldHost\":\"%\",\"is_migrate\":true},{\"user\":\"user2\",\"host\":\"%\",\"oldHost\":\"%\",\"is_migrate\":true}]

definer

Menentukan apakah akan mempertahankan definer asli objek database. Nilainya bisa true atau false.

amp.increment.generator.logmnr.mysql.heartbeat.mode

Ketika database sumber adalah MySQL yang dikelola sendiri.

Menentukan apakah akan menghapus pernyataan SQL tabel heartbeat untuk tugas maju dan balik. Nilai yang valid:

• none: Tidak menulis informasi SQL heartbeat ke database sumber.

• N: Menulis informasi SQL heartbeat ke database sumber.

whitelist.dms.online.ddl.enable

Untuk instans sinkronisasi atau migrasi ketika database tujuan adalah MySQL (termasuk RDS for MySQL dan MySQL yang dikelola sendiri), PolarDB for MySQL, AnalyticDB for MySQL, atau AnalyticDB for PostgreSQL.

Gunakan keenam parameter ini bersama-sama untuk mengontrol apakah akan menyalin tabel temporary ke database tujuan. Tabel-tabel ini dihasilkan ketika tool DDL online dijalankan pada tabel sumber.

• Untuk menyalin data dari tabel temporary yang dibuat oleh perubahan DDL online pada tabel sumber:

  {
     "whitelist.dms.online.ddl.enable": "true",
       "sqlparser.dms.original.ddl": "false",
       "whitelist.ghost.online.ddl.enable": "true",
       "sqlparser.ghost.original.ddl": "false"
  }

• Jangan menyalin data dari tabel temporary yang dibuat oleh perubahan DDL online. Sebagai gantinya, sinkronkan hanya pernyataan DDL asli yang dieksekusi DMS pada database sumber:

  {
     "whitelist.dms.online.ddl.enable": "false",
       "sqlparser.dms.original.ddl": "true",
       "whitelist.ghost.online.ddl.enable": "false",
       "sqlparser.ghost.original.ddl": "false"
  }

• Jangan menyalin data dari tabel temporary yang dibuat oleh perubahan DDL online. Sebagai gantinya, sinkronkan hanya pernyataan DDL asli yang dieksekusi gh-ost pada database sumber:

  {
     "whitelist.dms.online.ddl.enable": "false",
       "sqlparser.dms.original.ddl": "false",
       "whitelist.ghost.online.ddl.enable": "false",
       "sqlparser.ghost.original.ddl": "true",
       "online.ddl.shadow.table.rule": "^_(.+)_(?:gho|new)$",
       "online.ddl.trash.table.rule": "^_(.+)_(?:ghc|del|old)$"
  }

  Catatan

  Gunakan ekspresi reguler default atau konfigurasikan sendiri untuk tabel shadow gh-ost (online.ddl.shadow.table.rule) dan tabel sampah (online.ddl.trash.table.rule).

sqlparser.dms.original.ddl

whitelist.ghost.online.ddl.enable

sqlparser.ghost.original.ddl

online.ddl.shadow.table.rule

online.ddl.trash.table.rule

isAnalyzer

Parameter ini hanya berlaku ketika instans sumber dan tujuan keduanya merupakan database MySQL. Ini termasuk RDS MySQL dan MySQL yang dikelola sendiri.

Menentukan apakah akan mengaktifkan fitur evaluasi migrasi. Fitur ini menilai apakah struktur database sumber dan tujuan memenuhi persyaratan. Nilainya bisa true atau false.

srcSSL

Diperlukan ketika jenis koneksi adalah Instans Cloud atau Database yang Dikelola Sendiri di ECS.

Metode koneksi untuk database sumber. Nilai yang valid:

• 0: Koneksi tanpa enkripsi.

• 1: Koneksi terenkripsi SSL.

Parameter

Kondisi

Deskripsi

amp.increment.generator.logmnr.mysql.heartbeat.mode

Wajib

Menentukan apakah akan menghapus pernyataan SQL tabel heartbeat untuk tugas maju dan balik. Nilai yang valid:

• none: Tidak menulis informasi SQL heartbeat ke database sumber.

• N: Menulis informasi SQL heartbeat ke database sumber.

whitelist.dms.online.ddl.enable

Ketika database tujuan adalah MySQL (termasuk RDS for MySQL dan MySQL yang dikelola sendiri), PolarDB for MySQL, AnalyticDB for MySQL, atau AnalyticDB for PostgreSQL untuk tugas sinkronisasi atau migrasi.

Keenam parameter ini harus digunakan bersama untuk mengontrol apakah akan mereplikasi tabel temporary ke database tujuan. Tabel temporary dihasilkan ketika tool DDL online dijalankan pada tabel sumber.

• Untuk mereplikasi data dari tabel temporary yang dihasilkan oleh perubahan DDL online pada tabel sumber:

  {
     "whitelist.dms.online.ddl.enable": "true",
       "sqlparser.dms.original.ddl": "false",
       "whitelist.ghost.online.ddl.enable": "true",
       "sqlparser.ghost.original.ddl": "false"
  }

• Untuk menyinkronkan hanya data DDL asli yang dieksekusi oleh DMS pada database sumber, dan tidak mereplikasi data dari tabel temporary yang dihasilkan oleh perubahan DDL online:

  {
     "whitelist.dms.online.ddl.enable": "false",
       "sqlparser.dms.original.ddl": "true",
       "whitelist.ghost.online.ddl.enable": "false",
       "sqlparser.ghost.original.ddl": "false"
  }

• Untuk menyinkronkan hanya data DDL asli yang dieksekusi oleh gh-ost pada database sumber, dan tidak mereplikasi data dari tabel temporary yang dihasilkan oleh perubahan DDL online:

  {
     "whitelist.dms.online.ddl.enable": "false",
       "sqlparser.dms.original.ddl": "false",
       "whitelist.ghost.online.ddl.enable": "false",
       "sqlparser.ghost.original.ddl": "true",
       "online.ddl.shadow.table.rule": "^_(.+)_(?:gho|new)$",
       "online.ddl.trash.table.rule": "^_(.+)_(?:ghc|del|old)$"
  }

  Catatan

  Gunakan ekspresi reguler default atau konfigurasikan sendiri untuk tabel shadow gh-ost (online.ddl.shadow.table.rule) dan tabel sampah (online.ddl.trash.table.rule).

sqlparser.dms.original.ddl

whitelist.ghost.online.ddl.enable

sqlparser.ghost.original.ddl

online.ddl.shadow.table.rule

online.ddl.trash.table.rule

Parameter

Kondisi

Deskripsi

srcSSL

Ketika jenis koneksi adalah Instans Cloud atau Database yang Dikelola Sendiri di ECS.

Metode koneksi untuk database sumber. Nilai yang valid:

• 0: Koneksi tanpa enkripsi.

• 1: Koneksi terenkripsi SSL.

Parameter

Kondisi konfigurasi

Deskripsi

isTargetDbCaseSensitive

Wajib jika database tujuan adalah AnalyticDB for PostgreSQL.

Menentukan apakah akan menambahkan tanda kutip pada objek tujuan. Nilai yang valid adalah true dan false.

isNeedAddRowId

Wajib jika database tujuan adalah AnalyticDB for PostgreSQL dan objek untuk sinkronisasi atau migrasi mencakup tabel tanpa primary key.

Menentukan apakah akan menetapkan ROWID sebagai primary key dan kunci distribusi untuk semua tabel tanpa primary key. Nilai yang valid adalah true dan false.

srcOracleType

Wajib

Tipe instans Oracle. Nilai yang valid:

• sid: Instans non-RAC.

• serviceName: Instans Real Application Clusters (RAC) atau pluggable database (PDB).

source.column.encoding

Wajib untuk menentukan encoding tulis untuk bisnis Anda.

Encoding tulis untuk bisnis Anda. Encoding yang didukung:

• default (Default)

• GB 2312

• GBK

• GB 18030

• UTF-8

• UTF-16

• UTF-32

Parameter

Kondisi konfigurasi

Deskripsi

isTargetDbCaseSensitive

Ketika database tujuan adalah AnalyticDB for PostgreSQL.

Menentukan apakah akan menambahkan tanda kutip pada objek tujuan. Nilai yang valid adalah true dan false.

source.extractor.type

Wajib ketika database tujuan bukan DataHub dan tugas inkremental dikonfigurasi.

Mode untuk sinkronisasi atau migrasi inkremental untuk SQL Server. Nilai yang valid:

• cdc: Menggunakan penguraian log untuk sinkronisasi atau migrasi inkremental tabel non-heap, dan menggunakan Change Data Capture (CDC) untuk tabel heap.

• log: Mengurai log database sumber untuk sinkronisasi atau migrasi inkremental.

src.sqlserver.schema.mapper.mode

Ketika database tujuan adalah MySQL (termasuk ApsaraDB RDS for MySQL dan MySQL yang dikelola sendiri), PolarDB for MySQL, atau AnalyticDB for MySQL.

Mode pemetaan struktur antara database sumber dan tujuan. Nilai yang valid:

• schema.table: Menggunakan SchemaName.TableName dari database sumber sebagai nama tabel tujuan.

• without.schema: Menggunakan nama tabel dari database sumber sebagai nama tabel tujuan.

  Peringatan

  Jika tabel dengan nama yang sama ada di beberapa skema database sumber, ketidakkonsistenan data atau kegagalan tugas dapat terjadi.

Parameter

Kondisi konfigurasi

Deskripsi

srcKvStoreMode

Wajib ketika jenis koneksi instans database bukan Alibaba Cloud Instance.

Pola instans database Redis sumber yang dikelola sendiri. Nilai yang valid:

• single: Edisi Dasar.

• cluster: Edisi Kluster.

any.sink.redis.expire.extension.seconds

Wajib

Waktu tambahan dalam detik untuk memperpanjang waktu hidup (TTL) kunci saat dimigrasikan dari database sumber ke database tujuan. Untuk memastikan konsistensi data, atur TTL tambahan minimal 600 detik jika Anda menggunakan perintah seperti berikut.

EXPIRE key seconds
PEXPIRE key milliseconds
EXPIREAT key timestamp
PEXPIREAT key timestampMs

any.source.redis.use.slave.node

Wajib ketika srcKvStoreMode diatur ke cluster.

Menentukan apakah akan menarik data dari node slave. Nilai yang valid:

• true: Tarik data dari node slave.

• false (default): Tarik data dari node master.

Parameter

Kondisi

Deskripsi

srcEngineArchType

Wajib

Arsitektur database MongoDB sumber. Nilai yang valid:

• 0: Arsitektur single-node.

• 1: Arsitektur ReplicaSet.

• 2: Arsitektur kluster terpartisi.

sourceShardEndpointUsername

Wajib ketika srcEngineArchType diatur ke 2.

Username untuk shard database MongoDB sumber.

sourceShardEndpointPassword

Password untuk shard database MongoDB sumber.

Parameter

Kondisi konfigurasi

Deskripsi

amp.increment.generator.logmnr.mysql.heartbeat.mode

Wajib

Menentukan apakah akan menulis pernyataan SQL heartbeat untuk tugas maju dan balik. Nilai yang valid:

• none: Tidak menulis informasi SQL heartbeat ke database sumber.

• N: Menulis informasi SQL heartbeat ke database sumber.

Parameter

Kondisi

Deskripsi

srcHostPortCtl

Ketika jenis koneksi adalah alamat IP publik.

Menentukan apakah akan menggunakan sumber data tunggal atau ganda untuk PolarDB for PostgreSQL (Kompatibel dengan Oracle). Nilai yang valid:

• single: Single Data Source.

• multiple: Multiple Data Sources.

srcHostPorts

Ketika srcHostPortCtl diatur ke multiple.

Alamat IP dan nomor port node PolarDB for PostgreSQL (Kompatibel dengan Oracle) sumber. Pisahkan beberapa pasangan IP:Port dengan koma.

Parameter

Kondisi konfigurasi

Deskripsi

amp.increment.generator.logmnr.mysql.heartbeat.mode

Wajib

Menentukan apakah akan menghapus SQL untuk tabel heartbeat dari tugas maju dan balik:

• none: Tidak menulis pernyataan SQL heartbeat ke database sumber.

• N: Menulis pernyataan SQL heartbeat ke database sumber.

isIncMigration

Wajib

Menentukan apakah akan melakukan migrasi inkremental. Nilai yang valid adalah yes atau no.

srcKafka

Wajib jika isIncMigration diatur ke yes.

Informasi tentang kluster Kafka downstream TiDB.

taskType

Tipe kluster Kafka. Pilih tipe berdasarkan lokasi penerapan kluster Kafka. Nilai yang valid:

• EXPRESS: Leased Line / VPN Gateway / Smart Gateway.

• ECS: Database yang dikelola sendiri yang di-host di instans ECS.

bisId

• Jika taskType diatur ke ECS, parameter ini menentukan ID instans ECS.

• Jika taskType diatur ke EXPRESS, parameter ini menentukan ID virtual private cloud (VPC) yang terhubung ke database sumber.

port

Port layanan kluster Kafka.

user

Username untuk kluster Kafka. Biarkan kosong jika autentikasi dinonaktifkan untuk kluster Kafka.

passwd

Password untuk kluster Kafka. Biarkan kosong jika autentikasi dinonaktifkan untuk kluster Kafka.

version

Versi kluster Kafka.

ssl

Metode koneksi untuk kluster Kafka. Nilai yang valid:

• 0: Koneksi teks biasa.

• 3: Koneksi terenkripsi menggunakan SCRAM-SHA-256.

topic

Topik yang berisi objek untuk dimigrasikan atau disinkronkan.

host

Wajib jika taskType diatur ke EXPRESS.

Alamat IP kluster Kafka.

vpcId

Wajib jika taskType diatur ke ECS.

VPC tempat instans ECS berada.

Parameter

Kondisi konfigurasi

Deskripsi

privilegeMigration

Ketika tipe database sumber dan tujuan keduanya adalah RDS for MySQL. Untuk informasi selengkapnya, lihat Tipe database sumber adalah MySQL (termasuk RDS for MySQL dan MySQL yang dikelola sendiri).

Menentukan apakah akan memigrasikan akun.

privilegeDbList

Informasi tentang akun yang akan dimigrasikan.

definer

Menentukan apakah akan mempertahankan definer asli objek database.

whitelist.dms.online.ddl.enable

Ketika tipe database sumber adalah MySQL (termasuk RDS for MySQL dan MySQL yang dikelola sendiri) atau PolarDB for MySQL, dan instans digunakan untuk sinkronisasi atau migrasi. Untuk informasi selengkapnya, lihat Pengaturan parameter database sumber.

Keenam parameter ini harus digunakan bersama. Mereka mengontrol apakah akan mereplikasi tabel temporary yang dihasilkan oleh tool DDL online untuk tabel sumber ke database tujuan.

sqlparser.dms.original.ddl

whitelist.ghost.online.ddl.enable

sqlparser.ghost.original.ddl

online.ddl.shadow.table.rule

online.ddl.trash.table.rule

isAnalyzer

Ketika tipe database instans sumber dan tujuan keduanya adalah MySQL (termasuk RDS for MySQL dan MySQL yang dikelola sendiri).

Menentukan apakah akan mengaktifkan fitur evaluasi migrasi untuk menilai apakah struktur database sumber dan tujuan memenuhi persyaratan. Nilai yang valid adalah true dan false.

triggerMode

Wajib

Metode untuk memigrasikan trigger dari database sumber. Nilai yang valid:

• manual: Migrasikan trigger secara manual.

• auto: Migrasikan trigger secara otomatis.

destSSL

Ketika jenis koneksi adalah Instans Cloud atau Database yang Dikelola Sendiri yang di-host di ECS.

Metode koneksi untuk database tujuan. Nilai yang valid:

• 0: Koneksi non-terenkripsi.

• 1: Koneksi aman SSL.

src.sqlserver.schema.mapper.mode

Ketika tipe database sumber adalah SQL Server (termasuk RDS for SQL Server dan SQL Server yang dikelola sendiri).

Mode pemetaan struktur antara database sumber dan tujuan. Untuk informasi selengkapnya, lihat Tipe database sumber adalah SQL Server (termasuk RDS for SQL Server dan SQL Server yang dikelola sendiri).

Parameter

Kondisi konfigurasi

Deskripsi

whitelist.dms.online.ddl.enable

Ketika tipe database sumber adalah MySQL (termasuk RDS for MySQL dan MySQL yang dikelola sendiri) atau PolarDB for MySQL, dan instans digunakan untuk sinkronisasi atau migrasi. Untuk informasi selengkapnya, lihat Pengaturan parameter database sumber.

Keenam parameter ini harus digunakan bersama. Mereka mengontrol apakah akan mereplikasi tabel temporary yang dihasilkan oleh tool DDL online untuk tabel sumber ke database tujuan.

sqlparser.dms.original.ddl

whitelist.ghost.online.ddl.enable

sqlparser.ghost.original.ddl

online.ddl.shadow.table.rule

online.ddl.trash.table.rule

anySinkTableEngineType

Wajib

Tipe mesin instans PolarDB for MySQL. Nilai yang valid:

• innodb: Mesin penyimpanan default.

• xengine: Mesin penyimpanan database OLTP (On-Line Transaction Processing).

triggerMode

Wajib

Metode untuk memigrasikan trigger dari database sumber. Nilai yang valid:

• manual: Migrasikan trigger secara manual.

• auto: Migrasikan trigger secara otomatis.

src.sqlserver.schema.mapper.mode

Ketika tipe database sumber adalah SQL Server (termasuk RDS for SQL Server dan SQL Server yang dikelola sendiri).

Mode pemetaan struktur antara database sumber dan tujuan. Untuk informasi selengkapnya, lihat Tipe database sumber adalah SQL Server (termasuk RDS for SQL Server dan SQL Server yang dikelola sendiri).

Parameter

Kondisi konfigurasi

Deskripsi

whitelist.dms.online.ddl.enable

Ketika tipe database sumber adalah MySQL (termasuk RDS for MySQL dan MySQL yang dikelola sendiri) atau PolarDB for MySQL, dan instans digunakan untuk sinkronisasi atau migrasi. Untuk informasi selengkapnya, lihat Pengaturan parameter database sumber.

Keenam parameter ini harus digunakan bersama. Mereka mengontrol apakah akan mereplikasi tabel temporary yang dihasilkan oleh tool DDL online untuk tabel sumber ke database tujuan.

sqlparser.dms.original.ddl

whitelist.ghost.online.ddl.enable

sqlparser.ghost.original.ddl

online.ddl.shadow.table.rule

online.ddl.trash.table.rule

triggerMode

Wajib

Metode untuk memigrasikan trigger dari database sumber. Nilai yang valid:

• manual: Migrasikan trigger secara manual.

• auto: Migrasikan trigger secara otomatis.

src.sqlserver.schema.mapper.mode

Ketika tipe database sumber adalah SQL Server (termasuk RDS for SQL Server dan SQL Server yang dikelola sendiri).

Mode pemetaan struktur antara database sumber dan tujuan. Untuk informasi selengkapnya, lihat Tipe database sumber adalah SQL Server (termasuk RDS for SQL Server dan SQL Server yang dikelola sendiri).

traceDatasource

Wajib

Menentukan apakah akan mengaktifkan penggabungan multi-tabel. Nilai yang valid adalah true dan false.

tagColumnValue

Ketika Anda menentukan apakah akan menyesuaikan kolom tag.

Menentukan apakah akan menyesuaikan kolom tag __dts_data_source. Nilai yang valid:

• tagColumnValue: Sesuaikan kolom tag.

  Penting

  Anda juga perlu mengonfigurasi nilai kolom tag dalam parameter DbList. Untuk informasi selengkapnya, lihat Deskripsi objek untuk migrasi, sinkronisasi, atau langganan.

• notTagColumnValue: Jangan sesuaikan kolom tag.

  Penting

  Saat ini, hanya instans yang dikonfigurasi setelah pembelian yang mendukung kolom tag kustom.

adsSqlType

Ketika Anda perlu memilih operasi SQL untuk sinkronisasi atau migrasi inkremental di tingkat instans.

Memilih operasi SQL untuk sinkronisasi atau migrasi inkremental di tingkat instans. Pisahkan beberapa operasi SQL dengan koma. Nilai yang valid:

• insert

• update

• delete

• alterTable

• truncateTable

• createTable

• dropTable

Parameter

Kondisi konfigurasi

Deskripsi

whitelist.dms.online.ddl.enable

Ketika tipe database sumber adalah MySQL (termasuk RDS for MySQL dan MySQL yang dikelola sendiri) atau PolarDB for MySQL, dan instans digunakan untuk sinkronisasi atau migrasi. Untuk informasi selengkapnya, lihat Pengaturan parameter database sumber.

Keenam parameter ini harus digunakan bersama. Mereka mengontrol apakah akan mereplikasi tabel temporary yang dihasilkan oleh tool DDL online untuk tabel sumber ke database tujuan.

sqlparser.dms.original.ddl

whitelist.ghost.online.ddl.enable

sqlparser.ghost.original.ddl

online.ddl.shadow.table.rule

online.ddl.trash.table.rule

isTargetDbCaseSensitive

Ketika tipe database sumber adalah MySQL (termasuk RDS for MySQL dan MySQL yang dikelola sendiri), Oracle, atau SQL Server (termasuk RDS for SQL Server dan SQL Server yang dikelola sendiri).

Menentukan apakah akan menambahkan tanda kutip pada objek tujuan. Nilai yang valid adalah true dan false.

syncOperation

Ketika Anda perlu memilih operasi SQL untuk sinkronisasi atau migrasi inkremental di tingkat instans.

Memilih operasi SQL untuk sinkronisasi atau migrasi inkremental di tingkat instans. Pisahkan beberapa operasi SQL dengan koma. Nilai yang valid:

• insert

• update

• delete

• alterTable

• truncateTable

• createTable

• dropTable

• createDB

• dropDB

Parameter

Kondisi konfigurasi

Deskripsi

triggerMode

Wajib

Metode untuk memigrasikan trigger dari database sumber. Nilai yang valid:

• manual: Migrasikan trigger secara manual.

• auto: Migrasikan trigger secara otomatis.

destSSL

Ketika jenis koneksi adalah Instans Cloud atau Database yang Dikelola Sendiri yang di-host di ECS.

Metode koneksi untuk database tujuan. Nilai yang valid:

• 0: Koneksi non-terenkripsi.

• 1: Koneksi aman SSL.

Parameter

Kondisi konfigurasi

Deskripsi

destEngineArchType

Wajib

Tipe arsitektur database MongoDB tujuan. Nilai yang valid:

• 0 : Arsitektur single-node.

• 1: Arsitektur set replika.

• 2: Arsitektur kluster terpartisi.

Parameter

Kondisi konfigurasi

Deskripsi

destKvStoreMode

Ketika jenis koneksi untuk instans database bukan Alibaba Cloud Instance.

Mode instans Redis tujuan yang dikelola sendiri. Nilai yang valid:

• single: Edisi Dasar.

• cluster: Edisi Kluster.

any.sink.redis.expire.extension.seconds

Wajib

Waktu hidup tambahan (TTL) dalam detik untuk kunci saat dimigrasikan dari sumber ke database tujuan. Untuk memastikan konsistensi data, jika Anda menggunakan perintah seperti berikut, atur TTL tambahan kunci minimal 600 detik.

EXPIRE key seconds
PEXPIRE key milliseconds
EXPIREAT key timestamp
PEXPIREAT key timestampMs

Parameter

Kondisi konfigurasi

Deskripsi

destHostPortCtl

Ketika jenis koneksi adalah IP Publik.

Menentukan apakah akan memilih data multi-sumber untuk PolarDB for PostgreSQL (Kompatibel dengan Oracle). Nilai yang valid:

• single: Ini sesuai dengan Single Data Source.

• multiple: Ini sesuai dengan Multiple Data Sources.

destHostPorts

Ketika destHostPortCtl adalah multiple.

Alamat IP dan nomor port node PolarDB for PostgreSQL (Kompatibel dengan Oracle) tujuan. Pisahkan beberapa pasangan IP:Port dengan koma.

Parameter

Kondisi konfigurasi

Deskripsi

destOracleType

Wajib

Tipe instans Oracle. Nilai yang valid:

• sid: Instans non-RAC.

• serviceName: Instans RAC atau PDB.

Parameter

Kondisi konfigurasi

Deskripsi

isUseNewAttachedColumn

Wajib

Konvensi penamaan untuk kolom terlampir adalah sebagai berikut:

• Gunakan konvensi penamaan baru untuk kolom terlampir: Atur isUseNewAttachedColumn ke true.

• Gunakan konvensi penamaan kolom terlampir lama: isUseNewAttachedColumn diatur ke false.

Parameter

Kondisi konfigurasi

Deskripsi

isUseNewAttachedColumn

Wajib

Konvensi penamaan untuk kolom terlampir adalah sebagai berikut:

• Gunakan konvensi penamaan baru untuk kolom terlampir: Atur isUseNewAttachedColumn ke true.

• Menggunakan konvensi penamaan kolom terlampir lama: isUseNewAttachedColumn diatur ke false, .

partition

Wajib

Nama partisi tabel log inkremental. Nilai yang valid:

• Ketika isUseNewAttachedColumn adalah true:

  • modifytime_year

  • modifytime_month

  • modifytime_day

  • modifytime_hour

  • modifytime_minute

• Ketika isUseNewAttachedColumn adalah false:

  • new_dts_sync_modifytime_year

  • new_dts_sync_modifytime_month

  • new_dts_sync_modifytime_day

  • new_dts_sync_modifytime_hour

  • new_dts_sync_modifytime_minute

Parameter

Kondisi konfigurasi

Deskripsi

indexMapping

Wajib

Nama indeks yang dibuat di instans Elasticsearch tujuan. Nilai yang valid:

• tb: Nama indeks yang dibuat sama dengan nama tabel.

• db_tb: Nama indeks yang dibuat adalah kombinasi dari nama database, garis bawah (_), dan nama tabel.

Parameter

Kondisi konfigurasi

Deskripsi

destTopic

Wajib

Topik di kluster Kafka tujuan tempat objek migrasi atau sinkronisasi berada.

destVersion

Wajib

Versi kluster Kafka tujuan. Nilai yang valid adalah 1.0, 0.9, dan 0.10.

destSSL

Wajib

Metode untuk menghubungkan ke kluster Kafka tujuan. Nilai yang valid:

• 0: Koneksi non-terenkripsi.

• 3: Koneksi terenkripsi menggunakan SCRAM-SHA-256.

sink.kafka.ddl.topic

Ketika Anda perlu menentukan topik untuk menyimpan informasi DDL.

Topik yang digunakan untuk menyimpan informasi DDL. Jika Anda tidak memasukkan nilai, informasi DDL disimpan di topik yang ditentukan oleh destTopic secara default.

kafkaRecordFormat

Wajib

Format penyimpanan untuk data yang dikirimkan ke kluster Kafka tujuan. Nilai yang valid:

• canal_json: Menggunakan Canal untuk mengurai log inkremental database dan mengirimkan data inkremental ke kluster Kafka tujuan. Data disimpan dalam format JSON Canal.

• dts_avro: Format serialisasi data yang mengonversi struktur data atau objek menjadi format yang mudah disimpan atau dikirimkan.

• shareplex_json: Menggunakan perangkat lunak replikasi data Shareplex untuk membaca data dari database sumber. Saat menulis data ke kluster Kafka tujuan, data disimpan dalam format JSON Shareplex.

• debezium: Alat yang menangkap perubahan data dan mendukung streaming data update secara real-time dari database sumber ke kluster Kafka tujuan.

destKafkaPartitionKey

Wajib

Kebijakan sinkronisasi partisi Kafka. Nilai yang valid:

• none: Mengirimkan semua data dan informasi DDL ke partisi 0 topik tujuan.

• database_table: Menggabungkan nama database dan nama tabel untuk dijadikan kunci partisi untuk perhitungan hash. Kemudian, mengirimkan data dan informasi DDL setiap tabel ke partisi berbeda dari topik tujuan.

• columns: Menggunakan kolom dalam tabel (primary key secara default, atau unique key jika tidak ada primary key) sebagai kunci partisi untuk perhitungan hash. Kemudian, mengirimkan baris berbeda ke partisi berbeda dari topik tujuan. Anda juga dapat menentukan satu atau beberapa kolom sebagai kunci partisi untuk perhitungan hash.

destSchemaRegistry

Wajib

Menentukan apakah akan menggunakan Kafka Schema Registry. Nilai yang valid adalah yes dan no.

destKafkaSchemaRegistryUrl

Ketika destSchemaRegistry adalah true.

URL atau alamat IP untuk mendaftarkan skema Avro di Kafka Schema Registry.

Parameter

Kondisi konfigurasi

Deskripsi

fusionMetastoreMod

Wajib

Lokasi penyimpanan metadata OSS tujuan (katalog data). Nilai yang valid:

• dms: Disimpan di DMS.

• adb: Disimpan di kluster AnalyticDB for MySQL 3.0.

• none: Tidak ada. Metadata tidak disimpan.

fusionOssFilePath

Wajib

Direktori di OSS tujuan untuk penyimpanan data.

fusionOssFileFormat

Wajib

Format data terintegrasi di OSS tujuan. Nilai yang valid:

• DELTA: Format Delta.

• PARQUET: Format Parquet.

• HUDI: Format Hudi.

fusionAdbCrossMdsDbClusterId

Ketika fusionMetastoreMod adalah adb.

ID kluster AnalyticDB for MySQL 3.0 yang menyimpan metadata OSS tujuan.

fusionAdbCrossMdsRamId

Ketika fusionMetastoreMod adalah adb.

ID Akun Alibaba Cloud atau Pengguna RAM yang memiliki kluster AnalyticDB for MySQL 3.0 yang menyimpan metadata OSS tujuan.

srcConnArgs

Ketika database sumber adalah MySQL atau SQL Server.

Parameter koneksi database sumber dalam format JSON. Contoh:

"srcConnArgs": {
 "rewriteBatchedStatements": "true",
 "tinyInt1isBit": "false",
 "zeroDateTimeBehavior": "convertToNull",
 "yearIsDateType": "false"
 }

sparkExtraArgs

Ketika Anda mengonfigurasi parameter tugas Spark.

Parameter tugas Spark dalam format JSON. Contoh:

 "sparkExtraArgs": {
 "spark.executor.extraJavaOptions": "-verbose:class",
 "spark.driver.extraJavaOptions": "-verbose:class"
 }