Pasa un argumento del entorno de ejecución a un trabajo de replicación

En esta página, se describe cómo pasar argumentos de tiempo de ejecución en trabajos de replicación de Cloud Data Fusion.

Pasa un argumento de Debezium a un trabajo de replicación

Para pasar un argumento de una aplicación de Debezium a un trabajo de replicación de MySQL o SQL Server en Cloud Data Fusion, especifica un argumento de tiempo de ejecución con el prefijo source.connector.

Console

1. Ve a tu instancia:

   1. En la Google Cloud consola, ve a la página de Cloud Data Fusion.

   2. Para abrir la instancia en Cloud Data Fusion Studio, haz clic en Instancias y, luego, en Ver instancia.

      Ir a Instancias

2. Haz clic en Menú > Centro de control.

3. Busca la aplicación para el trabajo de replicación y haz clic en Preferencias. Se abrirá la ventana Preferencias.

4. En el campo Clave, especifica un argumento de tiempo de ejecución para el trabajo de replicación agregándole el prefijo source.connector.

   

5. Haz clic en Guardar y cerrar.

API de REST

Para establecer un argumento de tiempo de ejecución con la API de REST, consulta la referencia de microservicios de preferencias de CDAP.

Configura los parámetros de JDBC

Para pasar un parámetro de JDBC a un trabajo de replicación de MySQL o SQL Server, especifica el argumento de tiempo de ejecución con el prefijo source.connector.database.

Por ejemplo, para configurar el parámetro de JDBC sessionVariables en MAX_EXECUTION_TIME=43200000, establece un argumento de tiempo de ejecución con la clave source.connector.database.sessionVariables y el valor MAX_EXECUTION_TIME=43200000.

Para configurar varios parámetros de JDBC, establece un argumento de tiempo de ejecución para cada parámetro. Por ejemplo, para configurar los parámetros de JDBC encrypt=true&trustServerCertificate=true, pasa los siguientes argumentos:

Clave	Valor
source.connector.database.encrypt	true
source.connector.database.trustServerCertificate	true

Nota: Cloud Data Fusion no admite la configuración de argumentos de JDBC durante la configuración o la evaluación de un trabajo de replicación. Si debes establecer parámetros de JDBC para resolver problemas de evaluación, omite la evaluación implementando el trabajo de replicación a través de la API de Replication. Luego, antes de iniciar el trabajo, configura los argumentos de JDBC como se describió anteriormente en esta sección.

Configura el parámetro de clave primaria

La tabla de origen que se replica debe tener una clave primaria. Este es un requisito estricto solo cuando Oracle es la base de datos de origen. Para las fuentes de SQL Server y MySQL, puedes especificar una clave primaria personalizada, incluso si la tabla de origen no tiene una.

Establece el parámetro key con el siguiente argumento de tiempo de ejecución:

source.connector.message.key.columns = SCHEMA.TABLE:KEY_COLUMN

Reemplaza lo siguiente:

• SCHEMA: Es el nombre del esquema de origen.
• TABLE: Es el nombre de la tabla de origen.
• KEY_COLUMN: Es la columna que contiene la clave segura.

Puedes establecer la clave primaria para varias tablas con la propiedad key. En el siguiente ejemplo, se muestra cómo establecer la clave para las tablas inventory.customers y purchase.orders:

source.connector.message.key.columns = inventory.customers:pk1,pk2;purchase.orders:pk3,pk4

Configura el modo de aislamiento para una instantánea en la replicación de SQL Server

Para obtener más información sobre el argumento de tiempo de ejecución para el modo de aislamiento, consulta Niveles de aislamiento en la replicación de SQL Server.

¿Qué sigue?

• Obtén más información sobre la replicación en Cloud Data Fusion.
• Consulta la referencia de la API de replicación .