Auf dieser Seite wird beschrieben, wie Laufzeitargumente in Cloud Data Fusion-Replikationsjobs übergeben werden.
Hinweise
- Replikationsjob in einer Cloud Data Fusion-Instanz erstellen Weitere Informationen finden Sie unter Erste Schritte mit der Replikation.
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
Rufen Sie die Instanz auf:
Rufen Sie in der Google Cloud Console die Seite „Cloud Data Fusion“ auf.
Klicken Sie zum Öffnen der Instanz in der Cloud Data Fusion-Weboberfläche auf Instanzen und dann auf Instanz ansehen.
Klicken Sie auf > Kontrollzentrum.
MenüSuchen Sie die Anwendung für den Replikationsjob und klicken Sie auf
Einstellungen. Das Fenster Einstellungen wird geöffnet.Geben Sie im Feld Schlüssel ein Laufzeitargument für den Replikationsjob an, indem Sie ihm das Präfix
source.connector
voranstellen.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
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
- Weitere Informationen zur Replikation in Cloud Data Fusion
- Replication API-Referenz
- Anleitung zum Replizieren von Daten aus MySQL in BigQuery
- Anleitung zum Replizieren von Daten aus SQL Server in BigQuery
- Anleitung zum Replizieren von Daten aus Oracle in BigQuery