Transmita um argumento de tempo de execução a uma tarefa de replicação

Esta página descreve como transmitir argumentos de tempo de execução em tarefas de replicação do Cloud Data Fusion.

Transmita um argumento do Debezium a uma tarefa de replicação

Para transmitir um argumento de uma aplicação Debezium para uma tarefa de replicação do MySQL ou SQL Server no Cloud Data Fusion, especifique um argumento de tempo de execução com o prefixo source.connector.

Consola

  1. Aceda à sua instância:

    1. Na Google Cloud consola, aceda à página do Cloud Data Fusion.

    2. Para abrir a instância no Cloud Data Fusion Studio, clique em Instâncias e, de seguida, em Ver instância.

      Aceda a Instâncias

  2. Clique em Menu > Centro de controlo.

  3. Localize a Aplicação para a tarefa de replicação e clique em Preferências. É aberta a janela Preferências.

  4. No campo Chave, especifique um argumento de tempo de execução para a tarefa de replicação prefixando-o com source.connector.

    Aceda a Preferências e introduza source.connector como prefixo da chave.

  5. Clique em Guardar e fechar.

API REST

Para definir um argumento de tempo de execução através da API REST, consulte a referência dos microsserviços de preferências do CDAP.

Configure parâmetros JDBC

Para transmitir um parâmetro JDBC a uma tarefa de replicação do MySQL ou SQL Server, especifique o argumento de tempo de execução com o prefixo source.connector.database.

Por exemplo, para configurar o parâmetro JDBC sessionVariables para MAX_EXECUTION_TIME=43200000, defina um argumento de tempo de execução com a chave source.connector.database.sessionVariables e o valor MAX_EXECUTION_TIME=43200000.

Para configurar vários parâmetros JDBC, defina um argumento de tempo de execução para cada parâmetro. Por exemplo, para configurar os parâmetros JDBC encrypt=true&trustServerCertificate=true, transmita os seguintes argumentos:

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

Configure o parâmetro da chave principal

A tabela de origem replicada tem de ter uma chave principal. Este é um requisito rigoroso apenas quando o Oracle é a base de dados de origem. Para origens do SQL Server e MySQL, pode especificar uma chave primária personalizada, mesmo que a tabela de origem não tenha uma.

Defina o parâmetro key com o seguinte argumento de tempo de execução:

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

Substitua o seguinte:

  • SCHEMA: o nome do esquema de origem.
  • TABLE: o nome da tabela de origem.
  • KEY_COLUMN: a coluna que contém a chave segura.

Pode definir a chave principal para várias tabelas com a propriedade key. O exemplo seguinte mostra como definir a chave para as tabelas inventory.customers e purchase.orders:

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

Aceda a Preferências e defina o parâmetro de chave principal.

Configure o modo de isolamento para um instantâneo na replicação do SQL Server

Para mais informações sobre o argumento de tempo de execução para o modo de isolamento, consulte o artigo Níveis de isolamento na replicação do SQL Server.

O que se segue?