Passare un argomento di runtime a un job di replica

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

Passare un argomento Debezium a un job di replica

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

Console

1. Vai all'istanza:

   1. Nella console Google Cloud, vai alla pagina di 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 inserendo il prefisso 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 sui microservizi per le preferenze CDAP.

Configura parametri JDBC

Per passare un parametro JDBC a un job di replica MySQL o SQL Server, specifica l'argomento di runtime con 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, trasmetti 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. Quindi, prima di iniziare il job, configura gli argomenti JDBC come descritto in precedenza in questa sezione.

Configura il parametro della chiave primaria

La tabella di origine che viene 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 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 contenente la chiave di sicurezza.

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 di SQL Server

Per ulteriori informazioni sull'argomento 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 dell'API Replication.