Transmitir um argumento de ambiente de execução para um job de replicação

Nesta página, descrevemos como transmitir argumentos de ambiente de execução em jobs de replicação do Cloud Data Fusion.

Transmitir um argumento do Debezium para um job de replicação

Para transmitir um argumento do Debezium a um job de replicação do MySQL ou do SQL Server no Cloud Data Fusion, especifique um argumento de ambiente de execução com o prefixo source.connector.

Console

  1. Acesse sua instância:

    1. No console do Google Cloud, acesse a página do Cloud Data Fusion.

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

      Acesse "Instâncias"

  2. Clique em Menu > Central de Controle.

  3. Localize o Aplicativo do job de replicação e clique em Preferências. A janela Preferences é aberta.

  4. No campo Chave, especifique um argumento de ambiente de execução para o job de replicação com o prefixo source.connector.

    Acesse "Preferências" e insira source.connector como um prefixo da chave.

  5. Clique em Salvar e fechar.

API REST

Para definir um argumento de ambiente de execução usando a API REST, consulte a referência de microsserviços de preferências do CDAP.

Configurar os parâmetros do JDBC

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

Por exemplo, para configurar o parâmetro JDBC sessionVariables como MAX_EXECUTION_TIME=43200000, defina um argumento de ambiente 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 ambiente de execução para cada parâmetro. Por exemplo, para configurar os parâmetros encrypt=true&trustServerCertificate=true do JDBC, transmita os seguintes argumentos:

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

Configurar o parâmetro da chave primária

A tabela de origem que é replicada precisa ter uma chave primária. Esse é um requisito rigoroso apenas quando o Oracle é o banco de dados de origem. Para fontes do SQL Server e do MySQL, é possível 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 do ambiente de execução:

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

Substitua:

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

É possível definir a chave primária para várias tabelas com a propriedade key. O exemplo a seguir 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

Acesse "Preferências" e defina o parâmetro da chave primária.

Configurar o modo de isolamento de um snapshot na replicação do SQL Server

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

A seguir