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

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

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

Pasar un argumento de una aplicación Debezium a MySQL o SQL Server de replicación en Cloud Data Fusion, especifica un argumento del entorno de ejecución usando 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ú >. Centro de control.

  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.

    Ve a Preferencias y, luego, ingresa source.connector como prefijo de la clave.

  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 de JDBC sessionVariables de la siguiente manera: 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 entorno 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

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.

Configura el parámetro key con el siguiente argumento de entorno 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. El 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

Ve a Preferencias y establece el parámetro de clave primaria.

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?