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

Übergeben eines Arguments von einer Debezium-Anwendung an einen MySQL- oder SQL Server Replikationsjob in Cloud Data Fusion, geben Sie ein Laufzeitargument mit das Präfix source.connector.

Console

1. Rufen Sie Ihre Instanz auf:

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

   2. Um die Instanz in Cloud Data Fusion Studio zu öffnen, Klicken Sie auf Instanzen und dann auf Instanz ansehen.

      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.

Um beispielsweise den JDBC-Parameter sessionVariables so zu konfigurieren, MAX_EXECUTION_TIME=43200000, legen Sie ein Laufzeitargument fest mit dem Schlüssel source.connector.database.sessionVariables und dem Wert MAX_EXECUTION_TIME=43200000.

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 das Festlegen von JDBC-Argumenten während der Einrichtung oder Bewertung eines Replikationsjobs. Wenn Sie JDBC festlegen müssen Parameter, um Bewertungsprobleme zu beheben, die Bewertung zu umgehen, indem Sie den Replikationsjob über die Replikations-API Konfigurieren Sie dann vor dem Start des Jobs die JDBC-Argumente wie beschrieben zuvor in diesem Abschnitt beschrieben.

Primärschlüsselparameter konfigurieren

Die replizierte 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, die den sicheren Schlüssel enthält.

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

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