Laufzeitargument an einen Replikationsjob übergeben

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

Hinweise

Debezium-Argument an einen Replikationsjob übergeben

Wenn Sie das Argument Debezium 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 die Instanz auf:

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

    2. Klicken Sie zum Öffnen der Instanz in der Cloud Data Fusion-Weboberfläche 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.

    Gehen Sie zu den Einstellungen und geben Sie „source.connector“ als Präfix für den Schlüssel ein.

  5. Klicken Sie auf Speichern & schließen.

REST API

Informationen zum Festlegen eines Laufzeitarguments mithilfe der REST API finden Sie in der Referenz zu CDAP-Einstellungen zu Mikrodiensten.

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 für 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. Übergeben Sie beispielsweise die folgenden Argumente, um die JDBC-Parameter encrypt=true&trustServerCertificate=true zu konfigurieren:

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

Primärschlüsselparameter konfigurieren

Die Quelltabelle, die repliziert wird, muss einen Primärschlüssel haben. Dies ist nur dann eine strikte 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 enthält.

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 dem Attribut key können Sie den Primärschlüssel für mehrere Tabellen festlegen. Das folgende Beispiel zeigt, wie Sie den Schlüssel für die Tabellen inventory.customers und purchase.orders festlegen:

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

Gehen Sie zu den Einstellungen und legen Sie den Primärschlüsselparameter fest.

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

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

Nächste Schritte