Configure el parámetro Parameters al llamar a ModifyDtsJobConfig para modificar la configuración de las tareas de DTS.
Descripción de parámetros
Parameters es una cadena JSON. Especifique los campos a continuación:
-
module
Módulo del parámetro. Valores válidos:
03: Módulo Full Data Migration para tareas de migración o sincronización de datos.
04: Módulo Incremental Write para tareas de migración de datos.
07: Módulo Incremental Write para tareas de sincronización de datos.
60: Módulo de sincronización para tareas de Kafka a Kafka y de SLS a ClickHouse.
-
name
Nombre del parámetro, como se indica en la siguiente tabla.
-
value
Valor del parámetro, como se indica en la siguiente tabla.
|
Parámetro (name) |
Módulo configurable (module) |
Descripción (value) |
|
source.column.encoding |
03, 04 o 07 |
Codificación de caracteres de los datos de negocio en la base de datos Oracle de origen. Evita texto ilegible por incompatibilidad de conjuntos de caracteres. Valores válidos:
|
|
sink.worker.type |
03 |
Use los parámetros sink.worker.type y sink.bulk.copy.enable para configurar el modo de escritura de datos en bases de datos MySQL o PostgreSQL.
|
|
sink.bulk.copy.enable |
03 |
|
|
sink.batch.size.minimum |
03 |
Número mínimo de registros que escribe un hilo de escritura por lote. Valores válidos: de 0 a 1024. |
|
sink.batch.size.maximum |
03, 04 o 07 |
Valores válidos: de 0 a 1024. |
|
source.connection.idle.second |
03, 04 o 07 |
Tiempo de espera para reconexión a la base de datos de origen. Si DTS se reconecta dentro de este periodo, la tarea se reanuda automáticamente; de lo contrario, finaliza con errores. Valores válidos: de 0 a 86,400. Unidad: segundos. |
|
sink.connection.idle.second |
03, 04 o 07 |
Tiempo de espera para reconexión a la base de datos de destino. Si DTS se reconecta dentro de este periodo, la tarea se reanuda automáticamente; de lo contrario, finaliza con errores. Valores válidos: de 0 a 86,400. Unidad: segundos. |
|
trans.hot.merge.enable |
04 o 07 |
Habilita o deshabilita la fusión de puntos críticos. Valores válidos:
|
|
sink.batch.enable |
4, 7 |
Habilita o deshabilita la escritura de datos por lotes. Valores válidos:
|
|
source.filter.ddl.enable |
04 y 07 |
Habilita o deshabilita el filtrado de sentencias DDL. Valores válidos:
|
|
sink.ignore.failed.ddl |
04, 07 |
Habilita o deshabilita la omisión de sentencias DDL con errores. Valores válidos:
|
|
trans.size.maximum |
04, 07 |
Umbral de división de transacciones. Valores válidos: de 0 a 1024. |
|
dts.datamove.record.spouter.writers |
07 |
Número de hilos de escritura. Valores válidos: de 0 a 64. |
|
selectdb.reservoir.group.by.target.schema |
04 o 07 |
Agrupa la escritura de datos por nombre de tabla de destino. Valores válidos:
|
|
selectdb.reservoir.timeout.milliseconds |
04 o 07 |
Tiempo de espera para la escritura por lotes, en milisegundos.
|
|
sink.task.number |
03, 04, 07 o 60 |
Número de hilos de escritura para la base de datos de destino. Valores más altos mejoran el rendimiento de escritura en escenarios sin puntos críticos, pero incrementan la carga de la base de datos.
|
Ejemplo
Ejemplo en formato JSON:
[
{
"module": "07",
"name": "sink.connection.idle.second",
"value": 60
},
{
"module": "07",
"name": "sink.batch.size.maximum",
"value": 64
}
]