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.

Trasferire 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 Google Cloud console, 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 il riferimento 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 ogni 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 di 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, ignora la valutazione eseguendo il deployment del job di replica tramite l'API Replication. Poi, prima di iniziare il job, configura gli argomenti JDBC come descritto in precedenza in questa sezione.

Configurare il parametro della chiave primaria

La tabella di origine replicata deve avere una chiave primaria. Questo è 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

Configura la modalità di isolamento per uno snapshot nella replica 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 API di replica.