Data Transmission Service:Descrição do parâmetro Reserve

Parâmetro

Obrigatório

Descrição

targetTableMode

Sim

Modo de processamento para tabelas existentes no banco de dados de destino:

• 0: Executa uma pré-verificação e relata um erro para interromper a tarefa.

• 2: Ignora o erro e continua a tarefa.

dts.datamove.source.bps.max

Não

Quantidade máxima de dados que podem ser sincronizados ou migrados por segundo em uma tarefa completa ou incremental, em bytes (B).

conflict

Não

Política global de resolução de conflitos para uma tarefa de sincronização bidirecional. Valores válidos:

• overwrite: Se ocorrer um conflito de dados durante a sincronização, o registro conflitante no banco de dados de destino será substituído.

• interrupt: Se ocorrer um conflito de dados durante a sincronização, a tarefa de sincronização relatará um erro e será encerrada. A tarefa entrará no estado Failed. Corrija a tarefa manualmente.

• ignore: Se ocorrer um conflito de dados durante a sincronização, a instrução de sincronização atual será ignorada e a tarefa continuará. O registro conflitante no banco de dados de destino será mantido.

filterDDL

Não

Define se as operações DDL devem ser filtradas na tarefa direta de uma sincronização bidirecional. Valores válidos:

• true: Não sincroniza operações DDL.

• false: Sincroniza operações DDL.

  Importante

  A tarefa reversa filtra automaticamente as operações DDL.

autoStartModulesAfterConfig

Não

Parâmetro de controle de início da tarefa. Valores válidos:

• none: Após a configuração da tarefa do DTS, módulos como a pré-verificação não são iniciados. Inicie a tarefa manualmente.

• auto: Após a configuração da tarefa do DTS, o módulo de pré-verificação e todos os módulos subsequentes são iniciados automaticamente.

  Nota

  O valor padrão é auto para o cenário de compra antecipada. Este parâmetro não tem efeito no cenário de configuração antecipada.

etlOperatorCtl

Não

Define se o recurso de extração, transformação e carga (ETL) deve ser configurado. Valores válidos:

• Y: Sim, configura o recurso ETL.

• N: Não, não configura o recurso ETL.

etlOperatorSetting

Não

Instruções de processamento de dados para ETL. Para mais informações, consulte Sintaxe DSL de processamento de dados.

etlOperatorColumnReference

Não

Campo dedicado a serviços T+1. Trata-se de um operador ETL.

configKeyMap

Não

Informações de configuração do operador ETL.

syncArchitecture

Não

Topologia de sincronização. Valores válidos:

• oneway: sincronização unidirecional.

• bidirectional: sincronização bidirecional.

dataCheckConfigure

Não

Configuração de validação de dados. Para obter detalhes, consulte Descrição do parâmetro DataCheckConfigure.

dbListCaseChangeMode

Não

Política de diferenciação de maiúsculas e minúsculas para nomes de objetos no banco de dados de destino. Valores válidos:

• default: Usa a política padrão do DTS.

• source: Mantém a mesma capitalização do banco de dados de origem.

• dest_upper: Segue a política padrão do banco de dados de destino (maiúsculas).

• dest_lower: Segue a política padrão do banco de dados de destino (minúsculas).

maxRetryTime

Não

Tempo de espera antes de tentar reconectar ao banco de dados de origem ou de destino após uma exceção previsível, como erro de rede ou espera por bloqueio. O valor deve ser um número inteiro entre 600 e 86.400. A unidade é segundos. O valor padrão é 720 minutos (43.200 segundos). Defina este valor como 30 minutos (1.800 segundos) ou mais.

retry.blind.seconds

Não

Tempo de espera antes de tentar novamente após a ocorrência de uma exceção inesperada no banco de dados de origem ou de destino, como uma exceção de execução DDL ou DML. O valor deve ser um número inteiro entre 60 e 86.340. A unidade é segundos. O valor padrão é 10 minutos (600 segundos). Defina este valor como 10 minutos (600 segundos) ou mais.

modulesExtraConfiguration

Não

Itens de configuração estendida para módulos. Para obter informações sobre os parâmetros nos itens de configuração, consulte Descrição do parâmetro Parameters.

Formato: array JSON

Exemplo:

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

Parâmetro

Obrigatório

Descrição

vpcId

Sim

ID da virtual private cloud (VPC) onde a instância de assinatura reside.

vswitchId

Sim

ID do vSwitch da instância de assinatura.

startTime

Não

Hora de início da assinatura de dados, como timestamp UNIX em segundos.

endTime

Não

Hora de término da assinatura de dados, como timestamp UNIX em segundos.

consumerTime

Não

Ponto de verificação de consumo da assinatura, em segundos.

Parâmetro

Obrigatório

Descrição

srcInstanceId

Não

ID da instância CEN da instância de origem. Exemplo:

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

destInstanceId

Não

ID da instância CEN da instância de destino. Exemplo:

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

Parâmetro

Condição de configuração

Descrição

privilegeMigration

Aplica-se quando os bancos de dados de origem e de destino são ambos RDS for MySQL.

Define se as contas devem ser migradas. Valores válidos:

• true: Migra as contas.

• false (padrão): Não migra as contas.

privilegeDbList

Informações sobre as contas de migração. Para o formato do parâmetro, consulte Visualização de parâmetros de solicitação da OpenAPI. Exemplo:

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

definer

Define se o definer original do objeto de banco de dados deve ser mantido. O valor pode ser true ou false.

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

Quando o banco de dados de origem é MySQL autogerenciado.

Define se as instruções SQL da tabela de heartbeat devem ser removidas nas tarefas direta e reversa. Valores válidos:

• none: Não grava informações SQL de heartbeat no banco de dados de origem.

• N: Grava informações SQL de heartbeat no banco de dados de origem.

whitelist.dms.online.ddl.enable

Para instâncias de sincronização ou migração quando o banco de dados de destino é MySQL (incluindo RDS for MySQL e MySQL autogerenciado), PolarDB for MySQL, AnalyticDB for MySQL ou AnalyticDB for PostgreSQL.

Use estes seis parâmetros em conjunto para controlar se as tabelas temporárias devem ser copiadas para o banco de dados de destino. Essas tabelas são geradas quando uma ferramenta de DDL online é executada em uma tabela de origem.

• Para copiar dados de tabelas temporárias criadas por alterações DDL online na tabela de origem:

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

• Para não copiar dados de tabelas temporárias criadas por alterações DDL online, sincronizando apenas as instruções DDL originais executadas pelo DMS no banco de dados de origem:

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

• Para não copiar dados de tabelas temporárias criadas por alterações DDL online, sincronizando apenas as instruções DDL originais executadas pelo gh-ost no banco de dados de origem:

  {
         "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)$"
      }

  Nota

  Use as expressões regulares padrão ou configure expressões personalizadas para tabelas shadow do gh-ost (online.ddl.shadow.table.rule) e tabelas de lixo (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

Este parâmetro só tem efeito quando as instâncias de origem e de destino são bancos de dados MySQL. Isso inclui RDS MySQL e MySQL autogerenciado.

Define se o recurso de avaliação de migração deve ser ativado. Esse recurso avalia se as estruturas dos bancos de dados de origem e de destino atendem aos requisitos. O valor pode ser true ou false.

srcSSL

Obrigatório quando o tipo de conexão é Cloud Instance ou ECS Self-managed Database.

Método de conexão para o banco de dados de origem. Valores válidos:

• 0: Conexão não criptografada.

• 1: Conexão criptografada com SSL.

Parâmetro

Condição

Descrição

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

Obrigatório

Define se as instruções SQL da tabela de heartbeat devem ser removidas nas tarefas direta e reversa. Valores válidos:

• none: Não grava informações SQL de heartbeat no banco de dados de origem.

• N: Grava informações SQL de heartbeat no banco de dados de origem.

whitelist.dms.online.ddl.enable

Quando o banco de dados de destino é MySQL (incluindo RDS for MySQL e MySQL autogerenciado), PolarDB for MySQL, AnalyticDB for MySQL ou AnalyticDB for PostgreSQL em uma tarefa de sincronização ou migração.

Estes seis parâmetros devem ser usados em conjunto para controlar se as tabelas temporárias devem ser replicadas no banco de dados de destino. As tabelas temporárias são geradas quando uma ferramenta de DDL online é executada nas tabelas de origem.

• Para replicar dados de tabelas temporárias geradas por alterações DDL online na tabela de origem:

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

• Para sincronizar apenas os dados DDL originais executados pelo DMS no banco de dados de origem, sem replicar dados de tabelas temporárias geradas por alterações DDL online:

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

• Para sincronizar apenas os dados DDL originais executados pelo gh-ost no banco de dados de origem, sem replicar dados de tabelas temporárias geradas por alterações 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)$"
      }

  Nota

  Use as expressões regulares padrão ou configure suas próprias para tabelas shadow do gh-ost (online.ddl.shadow.table.rule) e tabelas de lixo (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

Parâmetro

Condição

Descrição

srcSSL

Quando o tipo de conexão é Cloud Instance ou Self-managed Database on ECS.

Método de conexão para o banco de dados de origem. Valores válidos:

• 0: Conexão não criptografada.

• 1: Conexão criptografada com SSL.

Parâmetro

Condição de configuração

Descrição

isTargetDbCaseSensitive

Obrigatório se o banco de dados de destino for AnalyticDB for PostgreSQL.

Define se aspas devem ser adicionadas aos objetos de destino. Os valores válidos são true e false.

isNeedAddRowId

Obrigatório se o banco de dados de destino for AnalyticDB for PostgreSQL e os objetos para sincronização ou migração incluírem tabelas sem chaves primárias.

Define se o ROWID deve ser definido como chave primária e chave de distribuição para todas as tabelas sem chaves primárias. Os valores válidos são true e false.

srcOracleType

Obrigatório

Tipo da instância Oracle. Valores válidos:

• sid: Uma instância não RAC.

• serviceName: Uma instância Real Application Clusters (RAC) ou pluggable database (PDB).

source.column.encoding

Obrigatório para especificar a codificação de gravação da sua aplicação.

Codificação de gravação da sua aplicação. Codificações suportadas:

• default (Padrão)

• GB 2312

• GBK

• GB 18030

• UTF-8

• UTF-16

• UTF-32

Parâmetro

Condição de configuração

Descrição

isTargetDbCaseSensitive

Quando o banco de dados de destino é AnalyticDB for PostgreSQL.

Define se aspas devem ser adicionadas aos objetos de destino. Os valores válidos são true e false.

source.extractor.type

Obrigatório quando o banco de dados de destino não é DataHub e uma tarefa incremental é configurada.

Modo de sincronização ou migração incremental para SQL Server. Os valores válidos são:

• cdc: Usa análise de log para sincronização ou migração incremental de tabelas non-heap e usa Change Data Capture (CDC) para tabelas heap.

• log: Analisa logs do banco de dados de origem para sincronização ou migração incremental.

src.sqlserver.schema.mapper.mode

Quando o banco de dados de destino é MySQL (incluindo ApsaraDB RDS for MySQL e MySQL autogerenciado), PolarDB for MySQL ou AnalyticDB for MySQL.

Modo de mapeamento de estrutura entre os bancos de dados de origem e de destino. Os valores válidos são:

• schema.table: Usa o SchemaName.TableName do banco de dados de origem como nome da tabela de destino.

• without.schema: Usa o nome da tabela do banco de dados de origem como nome da tabela de destino.

  Aviso

  Se existirem tabelas com o mesmo nome em vários schemas do banco de dados de origem, poderá ocorrer inconsistência de dados ou falha na tarefa.

Parâmetro

Condição de configuração

Descrição

srcKvStoreMode

Obrigatório quando o tipo de conexão da instância de banco de dados não é Alibaba Cloud Instance.

Padrão da instância do banco de dados Redis autogerenciado de origem. Valores válidos:

• single: Basic Edition.

• cluster: Cluster Edition.

any.sink.redis.expire.extension.seconds

Obrigatório

Tempo adicional em segundos para estender o time-to-live (TTL) de uma chave quando ela é migrada do banco de dados de origem para o de destino. Para garantir a consistência dos dados, defina o TTL estendido como 600 segundos ou mais se você usar comandos como os seguintes.

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

any.source.redis.use.slave.node

Obrigatório quando srcKvStoreMode está definido como cluster.

Define se os dados devem ser extraídos de um nó slave. Valores válidos:

• true: Extrai dados de um nó slave.

• false (padrão): Extrai dados do nó master.

Parâmetro

Condição

Descrição

srcEngineArchType

Obrigatório

Arquitetura do banco de dados MongoDB de origem. Valores válidos:

• 0: Arquitetura de nó único.

• 1: Arquitetura ReplicaSet.

• 2: Arquitetura de cluster fragmentado.

sourceShardEndpointUsername

Obrigatório quando srcEngineArchType está definido como 2.

Nome de usuário do shard do banco de dados MongoDB de origem.

sourceShardEndpointPassword

Senha do shard do banco de dados MongoDB de origem.

Parâmetro

Condição de configuração

Descrição

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

Obrigatório

Define se as instruções SQL de heartbeat devem ser gravadas nas tarefas direta e reversa. Valores válidos:

• none: Não grava informações SQL de heartbeat no banco de dados de origem.

• N: Grava informações SQL de heartbeat no banco de dados de origem.

Parâmetro

Condição

Descrição

srcHostPortCtl

Quando o tipo de conexão é endereço IP público.

Define se deve ser usada uma única origem ou múltiplas origens para PolarDB for PostgreSQL (Compatible with Oracle). Valores válidos:

• single: Single Data Source.

• multiple: Multiple Data Sources.

srcHostPorts

Quando srcHostPortCtl está definido como multiple.

Endereços IP e números de porta dos nós do PolarDB for PostgreSQL (Compatible with Oracle) de origem. Separe vários pares IP:Port com vírgulas.

Parâmetro

Condição de configuração

Descrição

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

Obrigatório

Define se o SQL da tabela de heartbeat deve ser removido das tarefas direta e reversa:

• none: Não grava instruções SQL de heartbeat no banco de dados de origem.

• N: Grava instruções SQL de heartbeat no banco de dados de origem.

isIncMigration

Obrigatório

Define se a migração incremental deve ser realizada. Os valores válidos são yes ou no.

srcKafka

Obrigatório se isIncMigration estiver definido como yes.

Informações sobre o cluster Kafka downstream do TiDB.

taskType

Tipo do cluster Kafka. Selecione um tipo com base no local de implantação do cluster Kafka. Valores válidos:

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

• ECS: Um banco de dados autogerenciado hospedado em uma instância ECS.

bisId

• Se taskType estiver definido como ECS, este parâmetro especifica o ID da instância ECS.

• Se taskType estiver definido como EXPRESS, este parâmetro especifica o ID da virtual private cloud (VPC) conectada ao banco de dados de origem.

port

Porta de serviço do cluster Kafka.

user

Nome de usuário do cluster Kafka. Deixe em branco se a autenticação estiver desativada para o cluster Kafka.

passwd

Senha do cluster Kafka. Deixe em branco se a autenticação estiver desativada para o cluster Kafka.

version

Versão do cluster Kafka.

ssl

Método de conexão para o cluster Kafka. Valores válidos:

• 0: Conexão em texto simples.

• 3: Conexão criptografada usando SCRAM-SHA-256.

topic

Tópico que contém os objetos a serem migrados ou sincronizados.

host

Obrigatório se taskType estiver definido como EXPRESS.

Endereço IP do cluster Kafka.

vpcId

Obrigatório se taskType estiver definido como ECS.

VPC onde a instância ECS reside.

Parâmetro

Condição de configuração

Descrição

privilegeMigration

Quando os tipos de banco de dados de origem e de destino são ambos RDS for MySQL. Para mais informações, consulte Tipo de banco de dados de origem é MySQL (incluindo RDS for MySQL e MySQL autogerenciado).

Define se as contas devem ser migradas.

privilegeDbList

Informações sobre as contas a serem migradas.

definer

Define se o definer original dos objetos de banco de dados deve ser mantido.

whitelist.dms.online.ddl.enable

Quando o tipo de banco de dados de origem é MySQL (incluindo RDS for MySQL e MySQL autogerenciado) ou PolarDB for MySQL, e a instância é para sincronização ou migração. Para mais informações, consulte Configurações de parâmetros do banco de dados de origem.

Estes seis parâmetros devem ser usados em conjunto. Eles controlam se as tabelas temporárias geradas pela ferramenta de DDL online para a tabela de origem devem ser replicadas no banco de dados de destino.

sqlparser.dms.original.ddl

whitelist.ghost.online.ddl.enable

sqlparser.ghost.original.ddl

online.ddl.shadow.table.rule

online.ddl.trash.table.rule

isAnalyzer

Quando o tipo de banco de dados das instâncias de origem e de destino é MySQL (incluindo RDS for MySQL e MySQL autogerenciado).

Define se o recurso de avaliação de migração deve ser ativado para avaliar se as estruturas dos bancos de dados de origem e de destino atendem aos requisitos. Os valores válidos são true e false.

triggerMode

Obrigatório

Método para migrar triggers do banco de dados de origem. Valores válidos:

• manual: Migra triggers manualmente.

• auto: Migra triggers automaticamente.

destSSL

Quando o tipo de conexão é Cloud Instance ou ECS-hosted Self-managed Database.

Método de conexão para o banco de dados de destino. Valores válidos:

• 0: Conexão não criptografada.

• 1: Conexão segura SSL.

src.sqlserver.schema.mapper.mode

Quando o tipo de banco de dados de origem é SQL Server (incluindo RDS for SQL Server e SQL Server autogerenciado).

Modo de mapeamento de estrutura entre os bancos de dados de origem e de destino. Para mais informações, consulte Tipo de banco de dados de origem é SQL Server (incluindo RDS for SQL Server e SQL Server autogerenciado).

Parâmetro

Condição de configuração

Descrição

whitelist.dms.online.ddl.enable

Quando o tipo de banco de dados de origem é MySQL (incluindo RDS for MySQL e MySQL autogerenciado) ou PolarDB for MySQL, e a instância é para sincronização ou migração. Para mais informações, consulte Configurações de parâmetros do banco de dados de origem.

Estes seis parâmetros devem ser usados em conjunto. Eles controlam se as tabelas temporárias geradas pela ferramenta de DDL online para a tabela de origem devem ser replicadas no banco de dados de destino.

sqlparser.dms.original.ddl

whitelist.ghost.online.ddl.enable

sqlparser.ghost.original.ddl

online.ddl.shadow.table.rule

online.ddl.trash.table.rule

anySinkTableEngineType

Obrigatório

Tipo de mecanismo da instância PolarDB for MySQL. Valores válidos:

• innodb: O mecanismo de armazenamento padrão.

• xengine: O mecanismo de armazenamento de banco de dados On-Line Transaction Processing (OLTP).

triggerMode

Obrigatório

Método para migrar triggers do banco de dados de origem. Valores válidos:

• manual: Migra triggers manualmente.

• auto: Migra triggers automaticamente.

src.sqlserver.schema.mapper.mode

Quando o tipo de banco de dados de origem é SQL Server (incluindo RDS for SQL Server e SQL Server autogerenciado).

Modo de mapeamento de estrutura entre os bancos de dados de origem e de destino. Para mais informações, consulte Tipo de banco de dados de origem é SQL Server (incluindo RDS for SQL Server e SQL Server autogerenciado).

Parâmetro

Condição de configuração

Descrição

whitelist.dms.online.ddl.enable

Quando o tipo de banco de dados de origem é MySQL (incluindo RDS for MySQL e MySQL autogerenciado) ou PolarDB for MySQL, e a instância é para sincronização ou migração. Para mais informações, consulte Configurações de parâmetros do banco de dados de origem.

Estes seis parâmetros devem ser usados em conjunto. Eles controlam se as tabelas temporárias geradas pela ferramenta de DDL online para a tabela de origem devem ser replicadas no banco de dados de destino.

sqlparser.dms.original.ddl

whitelist.ghost.online.ddl.enable

sqlparser.ghost.original.ddl

online.ddl.shadow.table.rule

online.ddl.trash.table.rule

triggerMode

Obrigatório

Método para migrar triggers do banco de dados de origem. Valores válidos:

• manual: Migra triggers manualmente.

• auto: Migra triggers automaticamente.

src.sqlserver.schema.mapper.mode

Quando o tipo de banco de dados de origem é SQL Server (incluindo RDS for SQL Server e SQL Server autogerenciado).

Modo de mapeamento de estrutura entre os bancos de dados de origem e de destino. Para mais informações, consulte Tipo de banco de dados de origem é SQL Server (incluindo RDS for SQL Server e SQL Server autogerenciado).

traceDatasource

Obrigatório

Define se a mesclagem de múltiplas tabelas deve ser ativada. Os valores válidos são true e false.

tagColumnValue

Quando você define se a coluna de tag deve ser personalizada.

Define se a coluna de tag __dts_data_source deve ser personalizada. Valores válidos:

• tagColumnValue: Personaliza a coluna de tag.

  Importante

  Você também precisa configurar o valor da coluna de tag no parâmetro DbList. Para mais informações, consulte Descrição de objetos para migração, sincronização ou assinatura.

• notTagColumnValue: Não personaliza a coluna de tag.

  Importante

  Atualmente, apenas instâncias configuradas após a compra suportam colunas de tag personalizadas.

adsSqlType

Quando é necessário selecionar operações SQL para sincronização ou migração incremental no nível da instância.

Seleciona as operações SQL para sincronização ou migração incremental no nível da instância. Separe múltiplas operações SQL com vírgulas. Valores válidos:

• insert

• update

• delete

• alterTable

• truncateTable

• createTable

• dropTable

Parâmetro

Condição de configuração

Descrição

whitelist.dms.online.ddl.enable

Quando o tipo de banco de dados de origem é MySQL (incluindo RDS for MySQL e MySQL autogerenciado) ou PolarDB for MySQL, e a instância é para sincronização ou migração. Para mais informações, consulte Configurações de parâmetros do banco de dados de origem.

Estes seis parâmetros devem ser usados em conjunto. Eles controlam se as tabelas temporárias geradas pela ferramenta de DDL online para a tabela de origem devem ser replicadas no banco de dados de destino.

sqlparser.dms.original.ddl

whitelist.ghost.online.ddl.enable

sqlparser.ghost.original.ddl

online.ddl.shadow.table.rule

online.ddl.trash.table.rule

isTargetDbCaseSensitive

Quando o tipo de banco de dados de origem é MySQL (incluindo RDS for MySQL e MySQL autogerenciado), Oracle ou SQL Server (incluindo RDS for SQL Server e SQL Server autogerenciado).

Define se aspas devem ser adicionadas aos objetos de destino. Os valores válidos são true e false.

syncOperation

Quando é necessário selecionar operações SQL para sincronização ou migração incremental no nível da instância.

Seleciona as operações SQL para sincronização ou migração incremental no nível da instância. Separe múltiplas operações SQL com vírgulas. Valores válidos:

• insert

• update

• delete

• alterTable

• truncateTable

• createTable

• dropTable

• createDB

• dropDB

Parâmetro

Condição de configuração

Descrição

triggerMode

Obrigatório

Método para migrar triggers do banco de dados de origem. Valores válidos:

• manual: Migra triggers manualmente.

• auto: Migra triggers automaticamente.

destSSL

Quando o tipo de conexão é Cloud Instance ou ECS-hosted Self-managed Database.

Método de conexão para o banco de dados de destino. Valores válidos:

• 0: Conexão não criptografada.

• 1: Conexão segura SSL.

Parâmetro

Condição de configuração

Descrição

destEngineArchType

Obrigatório

Tipo de arquitetura do banco de dados MongoDB de destino. Valores válidos:

• 0 : Arquitetura de nó único.

• 1: Arquitetura de replica set.

• 2: Arquitetura de cluster fragmentado.

Parâmetro

Condição de configuração

Descrição

destKvStoreMode

Quando o tipo de conexão da instância de banco de dados não é Alibaba Cloud Instance.

Modo da instância do Redis de destino autogerenciado. Valores válidos:

• single: Basic Edition.

• cluster: Cluster Edition.

any.sink.redis.expire.extension.seconds

Obrigatório

Tempo adicional de vida útil (TTL) em segundos para uma chave quando ela é migrada da origem para o banco de dados de destino. Para garantir a consistência dos dados, se você usar comandos como os seguintes, defina o TTL estendido da chave como 600 segundos ou mais.

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

Parâmetro

Condição de configuração

Descrição

destHostPortCtl

Quando o tipo de conexão é IP Público.

Define se dados de múltiplas origens devem ser selecionados para PolarDB for PostgreSQL (Compatible with Oracle). Valores válidos:

• single: Corresponde a Single Data Source.

• multiple: Corresponde a Multiple Data Sources.

destHostPorts

Quando destHostPortCtl é multiple.

Endereços IP e números de porta dos nós do PolarDB for PostgreSQL (Compatible with Oracle) de destino. Separe vários pares IP:Port com vírgulas.

Parâmetro

Condição de configuração

Descrição

destOracleType

Obrigatório

Tipo da instância Oracle. Valores válidos:

• sid: Uma instância não RAC.

• serviceName: Uma instância RAC ou PDB.

Parâmetro

Condição de configuração

Descrição

isUseNewAttachedColumn

Obrigatório

A convenção de nomenclatura para colunas anexadas é a seguinte:

• Usar a nova convenção de nomenclatura para colunas anexadas: Defina isUseNewAttachedColumn como true.

• Usar a antiga convenção de nomenclatura de colunas anexadas: isUseNewAttachedColumn está definido como false.

Parâmetro

Condição de configuração

Descrição

isUseNewAttachedColumn

Obrigatório

A convenção de nomenclatura para colunas anexadas é a seguinte:

• Usar a nova convenção de nomenclatura para colunas anexadas: Defina isUseNewAttachedColumn como true.

• Usando a antiga convenção de nomenclatura de colunas anexadas: isUseNewAttachedColumn está definido como false, .

partition

Obrigatório

Nome da partição da tabela de log incremental. Valores válidos:

• Quando isUseNewAttachedColumn é true:

  • modifytime_year

  • modifytime_month

  • modifytime_day

  • modifytime_hour

  • modifytime_minute

• Quando isUseNewAttachedColumn é 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

Parâmetro

Condição de configuração

Descrição

indexMapping

Obrigatório

Nome do índice criado na instância Elasticsearch de destino. Valores válidos:

• tb: O nome do índice criado é igual ao nome da tabela.

• db_tb: O nome do índice criado é uma combinação do nome do banco de dados, um sublinhado (_) e o nome da tabela.

Parâmetro

Condição de configuração

Descrição

destTopic

Obrigatório

Tópico no cluster Kafka de destino ao qual o objeto de migração ou sincronização pertence.

destVersion

Obrigatório

Versão do cluster Kafka de destino. Os valores válidos são 1.0, 0.9 e 0.10.

destSSL

Obrigatório

Método para conectar ao cluster Kafka de destino. Valores válidos:

• 0: Conexão não criptografada.

• 3: Conexão criptografada usando SCRAM-SHA-256.

sink.kafka.ddl.topic

Quando é necessário especificar um tópico para armazenar informações DDL.

Tópico usado para armazenar informações DDL. Se você não inserir um valor, as informações DDL serão armazenadas no tópico especificado por destTopic por padrão.

kafkaRecordFormat

Obrigatório

Formato de armazenamento para dados entregues ao cluster Kafka de destino. Valores válidos:

• canal_json: Usa o Canal para analisar logs incrementais do banco de dados e transmitir dados incrementais para o cluster Kafka de destino. Os dados são armazenados no formato Canal JSON.

• dts_avro: Um formato de serialização de dados que converte estruturas de dados ou objetos em um formato fácil de armazenar ou transmitir.

• shareplex_json: Usa o software de replicação de dados Shareplex para ler dados do banco de dados de origem. Ao gravar dados no cluster Kafka de destino, os dados são armazenados no formato Shareplex JSON.

• debezium: Uma ferramenta que captura alterações de dados e suporta streaming em tempo real de atualizações de dados do banco de dados de origem para o cluster Kafka de destino.

destKafkaPartitionKey

Obrigatório

Política de sincronização de partições do Kafka. Valores válidos:

• none: Entrega todos os dados e informações DDL para a partição 0 do tópico de destino.

• database_table: Mescla o nome do banco de dados e o nome da tabela para servir como chave de partição para cálculo de hash. Em seguida, entrega os dados e informações DDL de cada tabela para diferentes partições do tópico de destino.

• columns: Usa colunas na tabela (a chave primária por padrão, ou uma chave única se não houver chave primária) como chave de partição para cálculo de hash. Em seguida, entrega linhas diferentes para diferentes partições do tópico de destino. Você também pode especificar uma ou mais colunas como chave de partição para cálculo de hash.

destSchemaRegistry

Obrigatório

Define se o Kafka Schema Registry deve ser usado. Os valores válidos são yes e no.

destKafkaSchemaRegistryUrl

Quando destSchemaRegistry é true.

URL ou endereço IP para registrar o schema Avro no Kafka Schema Registry.

Parâmetro

Condição de configuração

Descrição

fusionMetastoreMod

Obrigatório

Local de armazenamento dos metadados do OSS de destino (catálogo de dados). Valores válidos:

• dms: Armazenado no DMS.

• adb: Armazenado em um cluster AnalyticDB for MySQL 3.0.

• none: Nenhum. Os metadados não são armazenados.

fusionOssFilePath

Obrigatório

Diretório no OSS de destino para armazenamento de dados.

fusionOssFileFormat

Obrigatório

Formato dos dados integrados no OSS de destino. Valores válidos:

• DELTA: Formato Delta.

• PARQUET: Formato Parquet.

• HUDI: Formato Hudi.

fusionAdbCrossMdsDbClusterId

Quando fusionMetastoreMod é adb.

ID do cluster AnalyticDB for MySQL 3.0 que armazena os metadados do OSS de destino.

fusionAdbCrossMdsRamId

Quando fusionMetastoreMod é adb.

ID da conta Alibaba Cloud ou usuário RAM que possui o cluster AnalyticDB for MySQL 3.0 que armazena os metadados do OSS de destino.

srcConnArgs

Quando o banco de dados de origem é MySQL ou SQL Server.

Parâmetros de conexão do banco de dados de origem no formato JSON. Por exemplo:

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

sparkExtraArgs

Quando você configura parâmetros de tarefa Spark.

Parâmetros da tarefa Spark no formato JSON. Por exemplo:

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