Passare un argomento di runtime a un job di replica

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

Passare un argomento Debezium a un job di replica

Per passare un argomento da un'applicazione Debezium a un server 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 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 anteponendo source.connector.

   

5. Fai clic su Salva e chiudi.

API REST

Per impostare un argomento di runtime utilizzando l'API REST, consulta Microservizi preferenze CDAP riferimento.

Configura parametri JDBC

Per passare un parametro JDBC a un job di replica MySQL o SQL Server, specifica l'argomento runtime preceduto dal 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 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 il configurazione o valutazione di un job di replica. Se devi impostare JDBC per risolvere i problemi di valutazione, bypassare la valutazione eseguendo il deployment il job di replica tramite 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 SQL Server e origini MySQL, puoi specificare una chiave primaria personalizzata, anche se l'origine e la tabella non ne ha uno.

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

Passaggi successivi

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