Data Transmission Service:Referencia del parámetro Reserve

Parámetro

Obligatorio

Descripción

targetTableMode

Sí

Manejo de tablas existentes en la base de datos de destino:

• 0: Ejecuta una verificación previa y bloquea la operación si ocurre un error.

• 2: Ignora los errores y continúa con la operación.

dts.datamove.source.bps.max

No

Cantidad máxima de datos por segundo para sincronizar o migrar en tareas completas o incrementales. Unidad: B (byte).

conflict

No

Directiva global de resolución de conflictos para tareas de sincronización bidireccional. Valores válidos:

• overwrite: Sobrescribe los registros en conflicto en la base de datos de destino cuando ocurre un conflicto.

• interrupt: Detiene la tarea de sincronización y la marca con errores cuando ocurre un conflicto. Debe corregir la tarea manualmente.

• ignore: Omite la instrucción de sincronización actual y continúa. Conserva el registro en conflicto en la base de datos de destino.

filterDDL

No

Indica si se filtran las operaciones DDL en tareas directas para sincronización bidireccional. Valores válidos:

• true: No sincroniza operaciones DDL.

• false: Sincroniza operaciones DDL.

  Importante

  Las tareas inversas filtran automáticamente las operaciones DDL.

autoStartModulesAfterConfig

No

Controla si se inician los módulos después de configurar la tarea. Valores válidos:

• none: Tras configurar la tarea DTS, no inicia la verificación previa ni otros módulos. Debe iniciar la tarea manualmente.

• auto: Tras configurar la tarea DTS, inicia automáticamente el módulo de verificación previa y todos los módulos subsiguientes.

  Nota

  En el escenario de compra previa a la configuración, el valor predeterminado es auto. En el escenario de configuración previa a la compra, este parámetro no surte efecto.

etlOperatorCtl

No

Indica si se habilitan las funciones ETL. Valores válidos:

• Y: Habilita las funciones ETL.

• No. No se configura la función ETL.

etlOperatorSetting

No

Instrucción de procesamiento de datos ETL. Para más información, consulte ETL DSL syntax.

etlOperatorColumnReference

No

Campo utilizado para negocios T+1. Es un operador ETL.

configKeyMap

No

Información de configuración del operador ETL.

syncArchitecture

No

Topología de sincronización. Valores válidos:

• oneway: Sincronización unidireccional.

• bidirectional: Sincronización bidireccional.

dataCheckConfigure

No

Configuración de validación de datos. Para más información, consulte DataCheckConfigure parameter reference.

dbListCaseChangeMode

No

Directiva de distinción entre mayúsculas y minúsculas para nombres de objetos en la base de datos de destino. Valores válidos:

• default: Utiliza la directiva predeterminada de DTS.

• source: Coincide con el uso de mayúsculas y minúsculas de la base de datos de origen.

• dest_upper: Utiliza mayúsculas, conforme a la directiva predeterminada de la base de datos de destino.

• dest_lower: Utiliza minúsculas, conforme a la directiva predeterminada de la base de datos de destino.

maxRetryTime

No

Tiempo de reintento en segundos tras un fallo de conexión en la base de datos de origen o destino. Este fallo es esperado, por ejemplo, debido a problemas de red o esperas de bloqueo. Valores válidos: enteros de 600 a 86400. Valor predeterminado: 43200 segundos (720 minutos). Se recomienda establecerlo como mínimo en 1800 segundos (30 minutos).

retry.blind.seconds

No

Tiempo de reintento en segundos tras fallos inesperados en la base de datos de origen o destino, como errores de ejecución DDL o DML. Valores válidos: enteros de 60 a 86340. Valor predeterminado: 600 segundos (10 minutos). Se recomienda establecerlo como mínimo en 600 segundos (10 minutos).

modulesExtraConfiguration

No

Elementos de configuración de extensión de módulo. Para detalles de los parámetros, consulte Parameters reference.

Formato: matriz JSON

Ejemplo:

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

Parámetro

Obligatorio

Descripción

vpcId

Sí

ID de la nube privada virtual (VPC) de la instancia de seguimiento.

vswitchId

Sí

ID del conmutador virtual de la instancia suscrita.

startTime

No

Marca de tiempo inicial para el seguimiento de datos. Unidad: segundos.

endTime

No

Marca de tiempo final de la suscripción de datos, en segundos.

Parámetro

Obligatorio

Descripción

srcInstanceId

No

ID de la instancia CEN de la instancia de origen. Ejemplo:

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

destInstanceId

No

ID de la instancia CEN de la instancia de destino. Ejemplo:

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

Parámetro

Condición

Descripción

privilegeMigration

Cuando tanto la base de datos de origen como la de destino son ApsaraDB RDS for MySQL.

Indica si se migran las cuentas. Valores válidos:

• true: Migra las cuentas.

• false (predeterminado): No migra las cuentas.

privilegeDbList

Información de migración de cuentas. Para determinar el formato correcto, utilice Preview OpenAPI request parameters. Ejemplo:

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

definer

Indica si se conserva el Definer original de los objetos de la base de datos. Valores válidos: true o false.

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

Cuando la base de datos de origen es una instancia de MySQL autogestionada.

Indica si se eliminan las sentencias SQL de la tabla de latido de las tareas directas e inversas. Valores válidos:

• none: No escribe información SQL de latido en la base de datos de origen.

• N: Escribe información SQL de latido en la base de datos de origen.

whitelist.dms.online.ddl.enable

Cuando el tipo de base de datos de destino es MySQL (incluye ApsaraDB RDS for MySQL y MySQL autogestionado), PolarDB for MySQL, AnalyticDB for MySQL o AnalyticDB for PostgreSQL, y se trata de una instancia de sincronización o migración.

Estos seis parámetros funcionan en conjunto para controlar si se replican las tablas temporales creadas durante los cambios de DDL en línea de la tabla de origen hacia la base de datos de destino.

• Replicar los datos de tablas temporales generados por los cambios de DDL en línea en la tabla de origen:

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

• No replicar los datos de tablas temporales generados por los cambios de DDL en línea en la tabla de origen. En su lugar, sincronizar solo las sentencias DDL originales ejecutadas por DMS en la base de datos de origen:

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

• No replicar los datos de tablas temporales generados por los cambios de DDL en línea en la tabla de origen. En su lugar, sincronizar solo las sentencias DDL originales ejecutadas por gh-ost en la base de datos de origen:

  {
         "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

  Puede usar las expresiones regulares predeterminadas o personalizarlas para las tablas sombra de gh-ost (online.ddl.shadow.table.rule) y las tablas de basura (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

Cuando tanto la base de datos de origen como la de destino son MySQL (incluye ApsaraDB RDS for MySQL y MySQL autogestionado).

Indica si se habilita la evaluación de migración para comprobar si las estructuras de las bases de datos de origen y destino cumplen con los requisitos. Valores válidos: true o false.

srcSSL

Cuando el método de conexión es una instancia en la nube o una base de datos autogestionada en ECS.

El método de conexión para la base de datos de origen. Valores válidos:

• 0: Conexión no cifrada.

• 1: Conexión segura SSL.

Parámetro

Requisitos de configuración

Descripción

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

Obligatorio

Indica si se eliminan las sentencias SQL de la tabla de latido de las tareas directas e inversas. Valores válidos:

• none: No escribe información SQL de latido en la base de datos de origen.

• N: Escribe información SQL de latido en la base de datos de origen.

whitelist.dms.online.ddl.enable

Cuando el tipo de base de datos de destino es MySQL (incluye ApsaraDB RDS for MySQL y MySQL autogestionado), PolarDB for MySQL, AnalyticDB for MySQL o AnalyticDB for PostgreSQL, y se trata de una instancia de sincronización o migración.

Estos seis parámetros funcionan en conjunto para controlar si se replican las tablas temporales creadas durante los cambios de DDL en línea de la tabla de origen hacia la base de datos de destino.

• Replicar los datos de tablas temporales generados por los cambios de DDL en línea en la tabla de origen:

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

• No replicar los datos de tablas temporales generados por los cambios de DDL en línea en la tabla de origen. En su lugar, sincronizar solo las sentencias DDL originales ejecutadas por DMS en la base de datos de origen:

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

• No replicar los datos de tablas temporales generados por los cambios de DDL en línea en la tabla de origen. En su lugar, sincronizar solo las sentencias DDL originales ejecutadas por gh-ost en la base de datos de origen:

  {
         "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

  Puede usar las expresiones regulares predeterminadas o personalizarlas para las tablas sombra de gh-ost (online.ddl.shadow.table.rule) y las tablas de basura (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

Requisitos previos

Descripción

srcSSL

Cuando el método de conexión es una instancia en la nube o una base de datos autogestionada en ECS.

El método de conexión para la base de datos de origen. Valores válidos:

• 0: Conexión no cifrada.

• 1: Conexión segura SSL.

Parámetro

Condición

Descripción

isTargetDbCaseSensitive

Cuando la base de datos de destino es AnalyticDB for PostgreSQL.

Indica si se agregan comillas alrededor de los objetos de destino. Valores válidos: true o false.

isNeedAddRowId

Cuando la base de datos de destino es AnalyticDB for PostgreSQL y los objetos a sincronizar o migrar incluyen tablas sin claves primarias.

Indica si se establece ROWID como clave primaria y clave de distribución para todas las tablas sin claves primarias. Valores válidos: true o false.

srcOracleType

Obligatorio

El tipo de la instancia de Oracle. Valores válidos:

• sid: Instancia que no es RAC.

• serviceName: Instancia RAC o de base de datos conectable (PDB).

source.column.encoding

Cuando necesita especificar la codificación que usa su aplicación para escribir datos.

La codificación que usa su aplicación para escribir datos. Codificaciones compatibles:

• default (predeterminado)

• GB 2312

• GBK

• GB 18030

• UTF-8

• UTF-16

• UTF-32

Parámetro

Requisitos previos

Descripción

isTargetDbCaseSensitive

Cuando la base de datos de destino es AnalyticDB for PostgreSQL.

Indica si se agregan comillas alrededor de los objetos de destino. Valores válidos: true o false.

source.extractor.type

Cuando la base de datos de destino no es DataHub y la tarea incluye operaciones incrementales.

El modo para la sincronización o migración incremental de SQL Server. Valores válidos:

• cdc: Usa análisis de registros para tablas que no son de montón y Change Data Capture (CDC) para tablas de montón.

• log: Analiza los registros de la base de datos de origen para la sincronización o migración incremental.

src.sqlserver.schema.mapper.mode

Cuando el tipo de base de datos de destino es MySQL (incluye ApsaraDB RDS for MySQL y MySQL autogestionado), PolarDB for MySQL o AnalyticDB for MySQL.

El modo de asignación de esquemas entre las bases de datos de origen y destino. Valores válidos:

• schema.table: Usa el Schema name.Table name de la base de datos de origen como nombre de la tabla de destino.

• without.schema: Usa el nombre de la tabla de la base de datos de origen como nombre de la tabla de destino.

  Aviso

  Si existen tablas con el mismo nombre en varios esquemas de la base de datos de origen, puede producirse inconsistencia de datos o fallo en la tarea.

Parámetro

Condiciones de configuración

Descripción

srcKvStoreMode

Cuando el método de conexión de la instancia de base de datos no es Alibaba Cloud Instance.

El modo de instancia de la base de datos de origen Redis autogestionada. Valores válidos:

• single: Basic Edition.

• cluster: Cluster Edition.

any.sink.redis.expire.extension.seconds

Obligatorio

El tiempo de vida (TTL) adicional, en segundos, que se agrega a las claves cuando se migran de la base de datos de origen a la de destino. Para garantizar la consistencia de los datos, si utiliza alguno de los siguientes comandos, se recomienda establecer este valor en 600 segundos como mínimo.

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

any.source.redis.use.slave.node

Cuando srcKvStoreMode es cluster.

Cuando la base de datos de origen Redis autogestionada está en modo clúster, elija si extraer datos del nodo maestro o esclavo. Valores válidos:

• true: Extrae datos del nodo esclavo.

• false (predeterminado): Extrae datos del nodo maestro.

Parámetro

Requisitos de configuración

Descripción

srcEngineArchType

Obligatorio

El tipo de arquitectura de la base de datos MongoDB de origen. Valores válidos:

• 0 : Instancia independiente.

• 1: ReplicaSet.

• 2: Clúster fragmentado.

sourceShardEndpointUsername

Cuando srcEngineArchType es 2.

El nombre de usuario del shard para la base de datos MongoDB de origen.

sourceShardEndpointPassword

La contraseña del shard para la base de datos MongoDB de origen.

Parámetro

Requisitos de configuración

Descripción

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

Obligatorio

Indica si se eliminan las sentencias SQL de la tabla de latido de las tareas directas e inversas. Valores válidos:

• none: No escribe información SQL de latido en la base de datos de origen.

• N: Escribe información SQL de latido en la base de datos de origen.

Parámetro

Condiciones de configuración

Descripción

srcHostPortCtl

Cuando el método de conexión es una dirección IP pública.

Indica si se seleccionan datos de múltiples orígenes para PolarDB for PostgreSQL (Compatible with Oracle). Valores válidos:

• single: Single Data Source.

• multiple: Multiple Data Sources.

srcHostPorts

Cuando srcHostPortCtl es multiple.

Las direcciones IP y números de puerto de los nodos de PolarDB for PostgreSQL (Compatible with Oracle) de origen. Separe varias entradas de IP:Port con comas inglesas.

Parámetro

Requisitos previos

Descripción

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

Obligatorio

Indica si se eliminan las sentencias SQL de la tabla de latido de las tareas directas e inversas. Valores válidos:

• none: No escribe información SQL de latido en la base de datos de origen.

• N: Escribe información SQL de latido en la base de datos de origen.

isIncMigration

Obligatorio

Indica si se realiza una migración incremental. Valores válidos: yes o no.

srcKafka

Cuando isIncMigration es yes.

Información de Kafka para el flujo descendente de TiDB.

taskType

El tipo de clúster de Kafka. Seleccione según dónde esté desplegado Kafka. Valores válidos:

• EXPRESS: Línea arrendada, VPN Gateway o Smart Access Gateway.

• ECS: Base de datos autogestionada en ECS.

bisId

• Cuando taskType es ECS, este es el ID de la instancia ECS.

• Cuando taskType es EXPRESS, este es el ID de la VPC conectada a la base de datos de origen.

port

El puerto de servicio del clúster de Kafka.

user

La cuenta del clúster de Kafka. Déjelo en blanco si la autenticación de Kafka está deshabilitada.

passwd

La contraseña del clúster de Kafka. Déjela en blanco si la autenticación de Kafka está deshabilitada.

version

La versión del clúster de Kafka.

ssl

El método de conexión para el clúster de Kafka. Valores válidos:

• 0: Conexión no cifrada.

• 3: Conexión cifrada mediante SCRAM-SHA-256.

topic

El tema para los objetos de migración o sincronización.

host

Cuando taskType es EXPRESS.

La dirección IP del clúster de Kafka.

vpcId

Cuando taskType es ECS.

La VPC de la instancia ECS.

Parámetro

Condición

Descripción

privilegeMigration

Cuando tanto la base de datos de origen como la de destino son ApsaraDB RDS for MySQL. Para obtener más información, consulte Source database type: MySQL (including ApsaraDB RDS for MySQL and self-managed MySQL).

Indica si se migran las cuentas.

privilegeDbList

Información de migración de cuentas.

definer

Indica si se conserva el Definer original de los objetos de la base de datos.

whitelist.dms.online.ddl.enable

Cuando el tipo de base de datos de origen es MySQL (incluye RDS MySQL y MySQL autogestionado) o PolarDB for MySQL, y la instancia es de sincronización o migración. Para obtener más información, consulte Source database parameter settings.

Estos seis parámetros funcionan en conjunto para controlar si se replican en la base de datos de destino las tablas temporales creadas durante los cambios de DDL en línea en la tabla de origen.

sqlparser.dms.original.ddl

whitelist.ghost.online.ddl.enable

sqlparser.ghost.original.ddl

online.ddl.shadow.table.rule

online.ddl.trash.table.rule

isAnalyzer

Cuando tanto la base de datos de origen como la de destino son MySQL (incluye ApsaraDB RDS for MySQL y MySQL autogestionado).

Indica si se habilita la evaluación de migración para comprobar si las estructuras de las bases de datos de origen y destino cumplen los requisitos. Valores válidos: true o false.

triggerMode

Obligatorio

El método de migración de triggers para la base de datos de origen. Valores válidos:

• manual: Migración manual.

• auto: Migración automática.

destSSL

Cuando el método de conexión es una instancia en la nube o una base de datos autogestionada en ECS.

El método de conexión para la base de datos de destino. Valores válidos:

• 0: Conexión no cifrada.

• 1: Conexión segura SSL.

src.sqlserver.schema.mapper.mode

Cuando la base de datos de origen es SQL Server (incluye ApsaraDB RDS for SQL Server y SQL Server autogestionado).

El modo de asignación de esquemas entre las bases de datos de origen y destino. Para obtener más información, consulte Source database type: SQL Server (including ApsaraDB RDS for SQL Server and self-managed SQL Server).

Parámetro

Requisitos previos

Descripción

whitelist.dms.online.ddl.enable

Cuando la base de datos de origen es MySQL (incluye ApsaraDB RDS for MySQL y MySQL autogestionado) o PolarDB for MySQL, y la tarea es una instancia de sincronización o migración. Para obtener más información, consulte Source database parameters.

Estos seis parámetros funcionan en conjunto para controlar si se replican en la base de datos de destino las tablas temporales creadas durante los cambios de DDL en línea en la tabla de origen.

sqlparser.dms.original.ddl

whitelist.ghost.online.ddl.enable

sqlparser.ghost.original.ddl

online.ddl.shadow.table.rule

online.ddl.trash.table.rule

anySinkTableEngineType

Obligatorio

El tipo de motor de la instancia de PolarDB for MySQL. Valores válidos:

• innodb: Motor de almacenamiento predeterminado.

• xengine: Motor de almacenamiento de base de datos para procesamiento de transacciones en línea (OLTP).

triggerMode

Obligatorio

El método de migración de triggers para la base de datos de origen. Valores válidos:

• manual: Migración manual.

• auto: Migración automática.

src.sqlserver.schema.mapper.mode

Cuando la base de datos de origen es SQL Server (incluye ApsaraDB RDS for SQL Server y SQL Server autogestionado).

El modo de asignación de esquemas entre las bases de datos de origen y destino. Para obtener más información, consulte Source database type: SQL Server (including ApsaraDB RDS for SQL Server and self-managed SQL Server).

Parámetro

Condición

Descripción

whitelist.dms.online.ddl.enable

Cuando la base de datos de origen es MySQL (incluye ApsaraDB RDS for MySQL y MySQL autogestionado) o PolarDB for MySQL, y la tarea es una instancia de sincronización o migración. Para obtener más información, consulte Source database parameters.

Estos seis parámetros funcionan en conjunto para controlar si se replican en la base de datos de destino las tablas temporales creadas durante los cambios de DDL en línea en la tabla de origen.

sqlparser.dms.original.ddl

whitelist.ghost.online.ddl.enable

sqlparser.ghost.original.ddl

online.ddl.shadow.table.rule

online.ddl.trash.table.rule

triggerMode

Obligatorio

El método de migración de triggers para la base de datos de origen. Valores válidos:

• manual: Migración manual.

• auto: Migración automática.

src.sqlserver.schema.mapper.mode

Cuando la base de datos de origen es SQL Server (incluye ApsaraDB RDS for SQL Server y SQL Server autogestionado).

El modo de asignación de esquemas entre las bases de datos de origen y destino. Para obtener más información, consulte Source database type: SQL Server (including ApsaraDB RDS for SQL Server and self-managed SQL Server).

traceDatasource

Obligatorio

Indica si se habilita la fusión de varias tablas. Valores válidos: true o false.

tagColumnValue

Cuando establece una columna de etiqueta personalizada.

Indica si se personaliza la columna de etiqueta __dts_data_source. Valores válidos:

• tagColumnValue: Personalizar la columna de etiqueta.

  Importante

  También debe configurar el valor de la columna de etiqueta en el parámetro DbList. Para obtener más información, consulte Migration, synchronization, or tracking object description.

• notTagColumnValue: No personalizar la columna de etiqueta.

  Importante

  Las columnas de etiqueta personalizadas solo son compatibles con el escenario de compra previa a la configuración.

adsSqlType

Cuando necesita seleccionar operaciones SQL de sincronización o migración incremental a nivel de instancia.

Las operaciones SQL para sincronización o migración incremental a nivel de instancia. Separe varias operaciones SQL con comas inglesas. Valores válidos:

• insert

• update

• delete

• alterTable

• truncateTable

• createTable

• dropTable

Parámetro

Requisitos previos

Descripción

whitelist.dms.online.ddl.enable

Cuando la base de datos de origen es MySQL (incluye ApsaraDB RDS for MySQL y MySQL autogestionado) o PolarDB for MySQL, y la tarea es una instancia de sincronización o migración. Para obtener más información, consulte Source database parameters.

Estos seis parámetros funcionan en conjunto para controlar si se replican en la base de datos de destino las tablas temporales creadas durante los cambios de DDL en línea en la tabla de origen.

sqlparser.dms.original.ddl

whitelist.ghost.online.ddl.enable

sqlparser.ghost.original.ddl

online.ddl.shadow.table.rule

online.ddl.trash.table.rule

isTargetDbCaseSensitive

Cuando la base de datos de origen es MySQL (incluye ApsaraDB RDS for MySQL y MySQL autogestionado), Oracle o SQL Server (incluye ApsaraDB RDS for SQL Server y SQL Server autogestionado).

Indica si se agregan comillas alrededor de los objetos de destino. Valores válidos: true o false.

syncOperation

Cuando necesita seleccionar operaciones SQL de sincronización o migración incremental a nivel de instancia.

Las operaciones SQL para sincronización o migración incremental a nivel de instancia. Separe varias operaciones SQL con comas inglesas. Valores válidos:

• insert

• update

• delete

• alterTable

• truncateTable

• createTable

• dropTable

• createDB

• dropDB

Parámetro

Condiciones de configuración

Descripción

triggerMode

Obligatorio

El método de migración de triggers para la base de datos de origen. Valores válidos:

• manual: Migración manual.

• auto: Migración automática.

destSSL

Cuando el método de conexión es una instancia en la nube o una base de datos autogestionada en ECS.

El método de conexión para la base de datos de destino. Valores válidos:

• 0: Conexión no cifrada.

• 1: Conexión segura SSL.

Parámetro

Condición

Descripción

destEngineArchType

Obligatorio

El tipo de arquitectura de la base de datos MongoDB de destino. Valores válidos:

• 0 : Instancia independiente.

• 1: ReplicaSet.

• 2: Clúster fragmentado.

Parámetro

Requisitos previos

Descripción

destKvStoreMode

Cuando el método de conexión de la instancia de base de datos no es Alibaba Cloud Instance.

El modo de instancia de la base de datos Redis de destino autogestionada. Valores válidos:

• single: Basic Edition.

• cluster: Cluster Edition.

any.sink.redis.expire.extension.seconds

Obligatorio

El tiempo de vida (TTL) adicional, en segundos, que se agrega a las claves cuando se migran de la base de datos de origen a la de destino. Para garantizar la consistencia de los datos, si utiliza alguno de los siguientes comandos, se recomienda establecer este valor en 600 segundos como mínimo.

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

Parámetro

Requisitos previos de configuración

Descripción

destHostPortCtl

Cuando el método de conexión es una dirección IP pública.

Indica si se seleccionan datos de múltiples orígenes para PolarDB for PostgreSQL (Compatible with Oracle). Valores válidos:

• single: Single Data Source.

• multiple: Multiple Data Sources.

destHostPorts

Cuando destHostPortCtl es multiple.

Las direcciones IP y números de puerto de los nodos de PolarDB for PostgreSQL (Compatible with Oracle) de destino. Separe varias entradas IP:Port con comas inglesas.

Parámetro

Condición

Descripción

destOracleType

Obligatorio

El tipo de instancia de Oracle. Valores válidos:

• sid: Instancia no RAC.

• serviceName: Instancia RAC o de base de datos conectable (PDB).

Parámetro

Condiciones de configuración

Descripción

isUseNewAttachedColumn

Obligatorio

La regla de nomenclatura para columnas adjuntas es la siguiente:

• Usar la nueva regla de nomenclatura: Establezca isUseNewAttachedColumn en true.

• Usar la regla de nomenclatura anterior: Establezca isUseNewAttachedColumn en false.

Parámetro

Condición

Descripción

isUseNewAttachedColumn

Obligatorio

La regla de nomenclatura para columnas adjuntas es la siguiente:

• Usar la nueva regla de nomenclatura: Establezca isUseNewAttachedColumn en true.

• Usar la regla de nomenclatura anterior: Establezca isUseNewAttachedColumn en false.

partition

Obligatorio

El nombre de partición para la tabla de registros incrementales. Valores válidos:

• Cuando isUseNewAttachedColumn es true:

  • modifytime_year

  • modifytime_month

  • modifytime_day

  • modifytime_hour

  • modifytime_minute

• Cuando isUseNewAttachedColumn es 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

Requisitos previos

Descripción

indexMapping

Obligatorio

El nombre del índice creado en la instancia de Elasticsearch de destino. Valores válidos:

• tb: El nombre del índice coincide con el nombre de la tabla.

• db_tb: El nombre del índice se forma al concatenar el nombre de la base de datos, un guion bajo (_) y el nombre de la tabla.

Parámetro

Requisitos previos

Descripción

destTopic

Obligatorio

El tema en el clúster de Kafka de destino para los objetos de migración o sincronización.

destVersion

Obligatorio

La versión del clúster de Kafka de destino. Valores válidos: 1.0, 0.9 o 0.10.

destSSL

Obligatorio

El método de conexión para el clúster de Kafka de destino. Valores válidos:

• 0: Conexión no cifrada.

• 3: Conexión cifrada mediante SCRAM-SHA-256.

sink.kafka.ddl.topic

Cuando necesita especificar un tema para almacenar información DDL.

El tema utilizado para almacenar información DDL. Si no especifica uno, la información DDL se almacena de forma predeterminada en el tema especificado en destTopic.

kafkaRecordFormat

Obligatorio

El formato de almacenamiento para los datos entregados al clúster de Kafka de destino. Valores válidos:

• canal_json: Utilice Canal para analizar sintácticamente los registros incrementales de la base de datos y entregar datos incrementales al clúster de Kafka de destino. El formato de almacenamiento de datos es Canal JSON.

• dts_avro: Un formato de serialización de datos que convierte estructuras de datos u objetos en formatos adecuados para almacenamiento o transmisión.

• shareplex_json: Utilice el software de replicación de datos Shareplex para leer datos de la base de datos de origen y escribirlos en el clúster de Kafka de destino. El formato de almacenamiento de datos es Shareplex JSON.

• debezium: Una herramienta que captura cambios en los datos y admite actualizaciones de datos en tiempo real mediante streaming desde la base de datos de origen hacia el clúster de Kafka de destino.

destKafkaPartitionKey

Obligatorio

La directiva de sincronización de particiones de Kafka. Valores válidos:

• none: Entregar todos los datos y la información DDL a la partición 0 del tema de destino.

• database_table: Combinar el nombre de la base de datos y el nombre de la tabla como clave de partición para calcular un valor hash. Luego, entregar los datos y la información DDL de cada tabla a diferentes particiones en el tema de destino.

• columns: Usar columnas de la tabla (de forma predeterminada, la clave principal; si no existe clave principal, usar la clave única) como clave de partición para calcular un valor hash. Luego, entregar diferentes filas a diferentes particiones en el tema de destino. También puede especificar una o más columnas como clave de partición para calcular el valor hash.

destSchemaRegistry

Obligatorio

Indica si se utiliza Kafka Schema Registry. Valores válidos: yes o no.

destKafkaSchemaRegistryUrl

Cuando destSchemaRegistry es true.

La URL o dirección IP donde se registra el esquema Avro en Kafka Schema Registry.

Parámetro

Requisitos previos

Descripción

fusionMetastoreMod

Obligatorio

La ubicación de almacenamiento para los metadatos de OSS de destino (catálogo de datos). Valores válidos:

• dms: Almacenar en DMS.

• adb: Almacenar en un clúster de AnalyticDB for MySQL 3.0.

• none: No almacenar metadatos.

fusionOssFilePath

Obligatorio

El directorio en OSS donde se almacenan los datos.

fusionOssFileFormat

Obligatorio

El formato de los datos integrados en el OSS de destino. Valores válidos:

• DELTA: Formato Delta.

• PARQUET: Formato Parquet.

• HUDI: Formato Hudi.

fusionAdbCrossMdsDbClusterId

Cuando fusionMetastoreMod es adb.

El ID del clúster de AnalyticDB for MySQL 3.0 que almacena los metadatos de OSS de destino.

fusionAdbCrossMdsRamId

Cuando fusionMetastoreMod es adb.

El ID de la cuenta de Alibaba Cloud (cuenta principal) o del usuario RAM (subcuenta) para el clúster de AnalyticDB for MySQL 3.0 que almacena los metadatos de OSS de destino.

srcConnArgs

Cuando la base de datos de origen es MySQL o SQL Server.

Los parámetros de conexión para la base de datos de origen en formato JSON. Ejemplo:

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

sparkExtraArgs

Cuando configura parámetros de tarea de Spark.

Los parámetros de tarea de Spark en formato JSON. Ejemplo:

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