Transferir un argumento del entorno de ejecución a una tarea de replicación

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

Transferir un argumento de Debezium a una tarea de replicación

Para transferir 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.

Consola

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, haga clic en Instancias y, a continuación, en Ver instancia.

      Ir a Instancias

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

3. Busca la aplicación del 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 la tarea de replicación añadiendo el prefijo source.connector.

   

5. Haz clic en Save & Close (Guardar y cerrar).

API REST

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

Configurar parámetros de JDBC

Para transferir un parámetro 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 JDBC sessionVariables en MAX_EXECUTION_TIME=43200000, define 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, define 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 JDBC durante la configuración o la evaluación de una tarea de replicación. Si debes definir 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 Replication. Después, antes de iniciar el trabajo, configura los argumentos de JDBC tal como se ha descrito anteriormente en esta sección.

Configurar el parámetro de clave principal

La tabla de origen que se replica debe tener una clave principal. Este requisito solo se aplica cuando Oracle es la base de datos de origen. En las fuentes de SQL Server y MySQL, puede especificar una clave principal personalizada, aunque la tabla de origen no tenga ninguna.

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

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

Haz los cambios siguientes:

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

Puede definir la clave principal de varias tablas con la propiedad key. En el siguiente ejemplo se muestra cómo definir la clave de las tablas inventory.customers y purchase.orders:

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

Configurar el modo de aislamiento de una captura en la replicación de SQL Server

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

Siguientes pasos

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