Configure o parâmetro Parameters ao chamar ModifyDtsJobConfig para modifique as configurações da tarefa do DTS.
Descrição dos parâmetros
Parameters é uma string JSON. Especifique os seguintes campos:
-
module
Módulo do parâmetro. Valores válidos:
03: Módulo Full Data Migration para tarefas de migração ou sincronização de dados.
04: Módulo Incremental Write para tarefas de migração de dados.
07: Módulo Incremental Write para tarefas de sincronização de dados.
60: Módulo de sincronização para tarefas Kafka-para-Kafka e SLS-para-ClickHouse.
-
name
Nome do parâmetro, conforme listado na tabela a seguir.
-
value
Valor do parâmetro, conforme listado na tabela a seguir.
|
Parâmetro (name) |
Módulo configurável (module) |
Descrição (value) |
|
source.column.encoding |
03, 04 ou 07 |
Codificação de caracteres dos dados de negócios no banco de dados Oracle de origem. Evita texto ilegível por incompatibilidade de conjuntos de caracteres. Valores válidos:
|
|
sink.worker.type |
03 |
Use os parâmetros sink.worker.type e sink.bulk.copy.enable para configure o modo de gravação de dados em bancos de dados MySQL ou PostgreSQL.
|
|
sink.bulk.copy.enable |
03 |
|
|
sink.batch.size.minimum |
03 |
Quantidade mínima de registros gravados por thread de gravação em cada lote. Valores válidos: 0 a 1024. |
|
sink.batch.size.maximum |
03, 04 ou 07 |
Valores válidos: 0 a 1024. |
|
source.connection.idle.second |
03, 04 ou 07 |
Tempo limite de reconexão do banco de dados de origem. Se o DTS se reconectar nesse período, a tarefa será retomada automaticamente; caso contrário, falhará. Valores válidos: 0 a 86.400. Unidade: segundos. |
|
sink.connection.idle.second |
03, 04 ou 07 |
Tempo limite de reconexão do banco de dados de destino. Se o DTS se reconectar nesse período, a tarefa será retomada automaticamente; caso contrário, falhará. Valores válidos: 0 a 86.400. Unidade: segundos. |
|
trans.hot.merge.enable |
04 ou 07 |
Ative ou desativa a mesclagem de hot spots. Valores válidos:
|
|
sink.batch.enable |
4, 7 |
Ative ou desativa a gravação de dados em lote. Valores válidos:
|
|
source.filter.ddl.enable |
04 e 07 |
Ative ou desativa a filtragem de instruções DDL. Valores válidos:
|
|
sink.ignore.failed.ddl |
04, 07 |
Ative ou desativa a opção de ignorar instruções DDL com falha. Valores válidos:
|
|
trans.size.maximum |
04, 07 |
Limiar de divisão de transações. Valores válidos: 0 a 1024. |
|
dts.datamove.record.spouter.writers |
07 |
Número de threads de gravação. Valores válidos: 0 a 64. |
|
selectdb.reservoir.group.by.target.schema |
04 ou 07 |
Agrupa a gravação de dados pelo nome da tabela de destino. Valores válidos:
|
|
selectdb.reservoir.timeout.milliseconds |
04 ou 07 |
Tempo limite para agrupamento de gravação, em milissegundos.
|
|
sink.task.number |
03, 04, 07 ou 60 |
Número de threads de gravação para o banco de dados de destino. Valores mais altos melhoram o desempenho de gravação em cenários sem hot spots, mas aumentam a carga no banco de dados.
|
Exemplo
Exemplo no formato JSON:
[
{
"module": "07",
"name": "sink.connection.idle.second",
"value": 60
},
{
"module": "07",
"name": "sink.batch.size.maximum",
"value": 64
}
]