Passare un argomento di runtime a un job di replica

Questa pagina descrive come passare gli argomenti di runtime nei job di replica di Cloud Data Fusion.

Passare un argomento Debezium a un job di replica

Per passare un argomento da un'applicazione Debezium a un job di replica MySQL o SQL Server in Cloud Data Fusion, specifica un argomento di runtime utilizzando il prefisso source.connector.

Console

1. Vai all'istanza:

   1. Nella console Google Cloud, vai alla pagina Cloud Data Fusion.

   2. Per aprire l'istanza in Cloud Data Fusion Studio, fai clic su Istanze e poi su Visualizza istanza.

      Vai a Istanze

2. Fai clic su Menu > Centro di controllo.

3. Individua l'applicazione per il job di replica e fai clic su Preferenze. Si apre la finestra Preferenze.

4. Nel campo Chiave, specifica un argomento di runtime per il job di replica anteponendo source.connector.

   

5. Fai clic su Salva e chiudi.

API REST

Per impostare un argomento di runtime utilizzando l'API REST, consulta la documentazione di riferimento dei microservizi delle preferenze CDAP.

Configurare i parametri JDBC

Per passare un parametro JDBC a un job di replica MySQL o SQL Server, specifica l'argomento di runtime con il prefisso source.connector.database.

Ad esempio, per configurare il parametro JDBC sessionVariables su MAX_EXECUTION_TIME=43200000, imposta un argomento di runtime con la chiave source.connector.database.sessionVariables e il valore MAX_EXECUTION_TIME=43200000.

Per configurare più parametri JDBC, imposta un argomento di runtime per ciascun parametro. Ad esempio, per configurare i parametri JDBC encrypt=true&trustServerCertificate=true, passa i seguenti argomenti:

Chiave	Valore
source.connector.database.encrypt	true
source.connector.database.trustServerCertificate	true

Nota: Cloud Data Fusion non supporta l'impostazione degli argomenti JDBC durante la configurazione o la valutazione di un job di replica. Se devi impostare i parametri JDBC per risolvere i problemi di valutazione, aggira la valutazione eseguendo il deployment del job di replica tramite l'API Replication. Quindi, prima di avviare il job, configura gli argomenti JDBC come descritto in precedenza in questa sezione.

Configura il parametro della chiave principale

La tabella di origine che viene replicata deve avere una chiave primaria. Si tratta di un requisito rigoroso solo quando Oracle è il database di origine. Per le origini SQL Server e MySQL, puoi specificare una chiave primaria personalizzata, anche se la tabella di origine non ne ha una.

Imposta il parametro key con il seguente argomento di runtime:

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

Sostituisci quanto segue:

• SCHEMA: il nome dello schema di origine.
• TABLE: il nome della tabella di origine.
• KEY_COLUMN: la colonna che contiene la chiave sicura.

Puoi impostare la chiave primaria per più tabelle con la proprietà key. L'esempio seguente mostra come impostare la chiave per le tabelle inventory.customers e purchase.orders:

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

Configurare la modalità di isolamento per uno snapshot nella replica di SQL Server

Per ulteriori informazioni sull'argomento di runtime per la modalità di isolamento, consulta Livelli di isolamento nella replica di SQL Server.

Passaggi successivi

• Scopri di più sulla replica in Cloud Data Fusion.
• Consulta il riferimento all'API Replication.