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 no Cloud Data Fusion os jobs de replicação do Compute Engine.

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

Transmitir um argumento de um aplicativo Debezium para um MySQL ou SQL Server de replicação do Cloud Data Fusion, especifique um argumento de ambiente de execução usando 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 depois 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 Preferências é 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 para a chave.

  5. Clique em Salvar e fechar.

API REST

Para definir um argumento de execução usando a API REST, consulte a referência 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 para 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 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

Configurar o parâmetro de chave primária

A tabela de origem que é replicada precisa ter uma chave primária. Esse é um requisito estrito apenas quando o Oracle é o banco de dados de origem. Para origens 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 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 abaixo 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 para 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