Laufzeitargument an einen Replikationsjob übergeben

Auf dieser Seite wird beschrieben, wie Sie Laufzeitargumente in Cloud Data Fusion-Replikationsjobs übergeben.

Debezium-Argument an einen Replikationsjob übergeben

Wenn Sie ein Argument von einer Debezium-Anwendung an einen MySQL- oder SQL Server-Replikationsjob in Cloud Data Fusion übergeben möchten, geben Sie ein Laufzeitargument mit dem Präfix source.connector an.

Console

1. Rufen Sie Ihre Instanz auf:

   1. Rufen Sie in der Google Cloud Console die Seite „Cloud Data Fusion“ auf.

   2. Wenn Sie die Instanz in Cloud Data Fusion Studio öffnen möchten, klicken Sie auf Instanzen und dann auf Instanz anzeigen.

      Zur Seite „VM-Instanzen“

2. Klicken Sie auf  Menü > Kontrollzentrum.

3. Suchen Sie die Anwendung für den Replikationsjob und klicken Sie auf Einstellungen. Das Fenster Einstellungen wird geöffnet.

4. Geben Sie im Feld Schlüssel ein Laufzeitargument für den Replikationsjob an, indem Sie ihm das Präfix source.connector voranstellen.

   

5. Klicken Sie auf Speichern & schließen.

REST API

Informationen zum Festlegen eines Laufzeitarguments mit der REST API finden Sie in der Referenz für CDAP-Einstellungen für Mikrodienste.

JDBC-Parameter konfigurieren

Wenn Sie einen JDBC-Parameter an einen MySQL- oder SQL Server-Replikationsjob übergeben möchten, geben Sie das Laufzeitargument mit dem Präfix source.connector.database an.

Wenn Sie beispielsweise den JDBC-Parameter sessionVariables auf MAX_EXECUTION_TIME=43200000 konfigurieren möchten, legen Sie ein Laufzeitargument mit dem Schlüssel source.connector.database.sessionVariables und dem Wert MAX_EXECUTION_TIME=43200000 fest.

Wenn Sie mehrere JDBC-Parameter konfigurieren möchten, legen Sie für jeden Parameter ein Laufzeitargument fest. Wenn Sie beispielsweise die JDBC-Parameter encrypt=true&trustServerCertificate=true konfigurieren möchten, übergeben Sie die folgenden Argumente:

Schlüssel	Wert
source.connector.database.encrypt	true
source.connector.database.trustServerCertificate	true

Hinweis: Cloud Data Fusion unterstützt nicht das Festlegen von JDBC-Argumenten bei der Einrichtung oder Bewertung eines Replikationsjobs. Wenn Sie JDBC-Parameter festlegen müssen, um Probleme bei der Bewertung zu beheben, können Sie die Bewertung umgehen, indem Sie den Replikationsjob über die Replikations API bereitstellen. Konfigurieren Sie dann vor dem Starten des Jobs die JDBC-Argumente wie oben in diesem Abschnitt beschrieben.

Primärschlüsselparameter konfigurieren

Die zu replizierende Quelltabelle muss einen Primärschlüssel haben. Dies ist nur dann eine strenge Anforderung, wenn Oracle die Quelldatenbank ist. Für SQL Server- und MySQL-Quellen können Sie einen benutzerdefinierten Primärschlüssel angeben, auch wenn die Quelltabelle keinen hat.

Legen Sie den Parameter key mit dem folgenden Laufzeitargument fest:

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

Ersetzen Sie Folgendes:

• SCHEMA: Der Name des Quellschemas.
• TABLE: Der Name der Quelltabelle.
• KEY_COLUMN: Die Spalte mit dem sicheren Schlüssel.

Mit der Property key können Sie den Primärschlüssel für mehrere Tabellen festlegen. Im folgenden Beispiel wird gezeigt, wie der Schlüssel für die Tabellen inventory.customers und purchase.orders festgelegt wird:

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

Isolationsmodus für einen Snapshot in der SQL Server-Replikation konfigurieren

Weitere Informationen zum Laufzeitargument für den Isolationsmodus finden Sie unter Isolationsebenen in der SQL Server-Replikation.

Nächste Schritte

• Weitere Informationen zur Replikation in Cloud Data Fusion
• Replication API-Referenz