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 una tarea 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 consola de Google Cloud, 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ú > Control Center.

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

4. En el campo Clave, especifica un argumento del entorno de ejecución para la tarea de replicación con 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 JDBC a una tarea de replicación de MySQL o SQL Server, especifica el argumento del entorno de ejecución con el prefijo source.connector.database.

Por ejemplo, para configurar el parámetro 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 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 JDBC durante la configuración o evaluación de un trabajo de replicación. Si debes configurar parámetros JDBC para resolver problemas de evaluación, inhabilita 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 principal

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. En el caso de 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 de varias tablas con la propiedad key. En el siguiente ejemplo, se muestra cómo configurar 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 del entorno 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.