Die Vorlage "SourceDB zu Spanner" ist eine Batchpipeline, die Daten aus einer relationalen Datenbank in eine vorhandene Spanner-Datenbank kopiert. Diese Pipeline verwendet JDBC, um eine Verbindung zur relationalen Datenbank herzustellen. Sie können mit dieser Vorlage Daten aus einer beliebigen relationalen Datenbank mit den verfügbaren JDBC-Treibern nach Spanner kopieren. Es werden nur eine begrenzte Anzahl von MySQL-Typen unterstützt.
Als zusätzliche Schutzmaßnahme können Sie einen Cloud KMS-Schlüssel zusammen mit einem Base64-codierten Nutzernamen, Passwort und Verbindungsstring-Parametern übergeben, die mit dem Cloud KMS-Schlüssel verschlüsselt sind. Weitere Informationen zum Verschlüsseln von Nutzernamen, Passwörtern und Verbindungsstring-Parametern finden Sie unter Cloud KMS API-Verschlüsselungsendpunkt.
Pipelineanforderungen
- Die JDBC-Treiber für die relationale Datenbank müssen verfügbar sein.
- Die Spanner-Tabellen müssen vor der Pipelineausführung vorhanden sein.
- Die Spanner-Tabellen müssen ein kompatibles Schema haben.
- Die relationale Datenbank muss über das Subnetz zugänglich sein, in dem Dataflow ausgeführt wird.
Vorlagenparameter
Parameter | Beschreibung |
---|---|
sourceConfigURL |
Der URL-String für die JDBC-Verbindung. Beispiel: jdbc:mysql://127.4.5.30:3306/my-db?autoReconnect=true&maxReconnects=10&unicode=true&characterEncoding=UTF-8 oder die Shard-Konfiguration. |
instanceId |
Die Cloud Spanner-Zielinstanz. |
databaseId |
Die Ziel-Cloud Spanner-Datenbank. |
projectId |
Dies ist der Name des Cloud Spanner-Projekts. |
outputDirectory |
Dieses Verzeichnis wird verwendet, um die fehlgeschlagenen/übersprungenen/gefilterten Datensätze bei einer Migration zu verschieben. |
jdbcDriverJars |
Optional: Die durch kommagetrennte Liste der JAR-Dateien des Treibers. Beispiel:
gs://your-bucket/driver_jar1.jar,gs://your-bucket/driver_jar2.jar . Die Standardeinstellung ist leer. |
jdbcDriverClassName |
Optional: Der Name der JDBC-Treiberklasse. Beispiel: com.mysql.jdbc.Driver . Standardeinstellung:
com .mysql.jdbc.Driver. |
username |
Optional: Der Nutzername, der für die JDBC-Verbindung verwendet werden soll. Die Standardeinstellung ist leer. |
password |
Optional: Das Passwort für die JDBC-Verbindung. Die Standardeinstellung ist leer. |
tables |
Optional: Tabellen, die aus der Quelle migriert werden sollen. Die Standardeinstellung ist leer. |
numPartitions |
Optional: Die Anzahl der Partitionen. Damit bilden zusammen mit der Unter- und Obergrenze die Partitionsschritte für generierte WHERE-Klauselausdrücke, die zum gleichmäßigen Aufteilen der Partitionsspalte verwendet werden. Wenn die Eingabe kleiner als 1 ist, wird die Zahl auf 1 gesetzt.
Die Standardeinstellung ist 0 . |
spannerHost |
Optional: Der Cloud Spanner-Endpunkt, der in der Vorlage aufgerufen werden soll. Beispiel:
https://batch-spanner.googleapis.com . Standardeinstellung: https://batch-spanner .googleapis.com. |
maxConnections |
Optional: Konfiguriert den JDBC-Verbindungspool auf jedem Worker mit der maximalen Anzahl von Verbindungen. Verwenden Sie eine negative Zahl, wenn Sie kein Limit haben. Beispiel: -1 . Die Standardeinstellung ist 0 . |
sessionFilePath |
Optional: Sitzungspfad in Cloud Storage, der Zuordnungsinformationen aus dem Spanner-Migrationstool enthält. Die Standardeinstellung ist leer. |
transformationJarPath |
Optional: Benutzerdefinierter JAR-Speicherort in Cloud Storage, der die benutzerdefinierte Transformationslogik für die Verarbeitung von Einträgen enthält. Die Standardeinstellung ist leer. |
transformationClassName |
Optional: Vollständig qualifizierter Klassenname mit benutzerdefinierter Transformationslogik. Dies ist ein Pflichtfeld, falls transformationJarPath angegeben ist. Die Standardeinstellung ist leer. |
transformationCustomParameters |
Optional: String mit allen benutzerdefinierten Parametern, die an die benutzerdefinierte Transformationsklasse übergeben werden sollen. Die Standardeinstellung ist leer. |
disabledAlgorithms |
Optional: Durch Kommas getrennte Algorithmen zum Deaktivieren. Wenn dieser Wert auf „Keine“ gesetzt ist, wird kein Algorithmus deaktiviert. Verwenden Sie diesen Parameter mit Vorsicht, da die standardmäßig deaktivierten Algorithmen Sicherheitslücken oder Leistungsprobleme haben können. Beispiel:
SSLv3, RC4 . |
extraFilesToStage |
Optional: Durch Kommas getrennte Cloud Storage-Pfade oder Secret Manager-Secrets für Dateien, die im Worker bereitgestellt werden sollen. Diese Dateien werden im Verzeichnis /extra_files in jedem Worker gespeichert. Beispiel:
gs://<BUCKET>/file.txt,projects/<PROJECT_ID>/secrets/<SECRET_ID>/versions/<VERSION_ID> . |
Führen Sie die Vorlage aus.
Console
- Rufen Sie die Dataflow-Seite Job aus Vorlage erstellen auf. Zur Seite "Job aus Vorlage erstellen“
- Geben Sie im Feld Jobname einen eindeutigen Jobnamen ein.
- Optional: Wählen Sie für Regionaler Endpunkt einen Wert aus dem Drop-down-Menü aus. Die Standardregion ist
us-central1
.Eine Liste der Regionen, in denen Sie einen Dataflow-Job ausführen können, finden Sie unter Dataflow-Standorte.
- Wählen Sie im Drop-down-Menü Dataflow-Vorlage die Option the Sourcedb to Spanner templateaus.
- Geben Sie Ihre Parameterwerte in die Parameterfelder ein.
- Klicken Sie auf Job ausführen.
gcloud-CLI
Führen Sie die Vorlage in der Shell oder im Terminal aus:
gcloud dataflow flex-template run JOB_NAME \ --template-file-gcs-location=gs://dataflow-templates-REGION_NAME/VERSION/flex/Sourcedb_to_Spanner_Flex \ --project=PROJECT_ID \ --region=REGION_NAME \ --parameters \ sourceConfigURL=SOURCE_CONFIG_URL,\ instanceId=INSTANCE_ID,\ databaseId=DATABASE_ID,\ projectId=PROJECT_ID,\ outputDirectory=OUTPUT_DIRECTORY,\
Ersetzen Sie Folgendes:
JOB_NAME
: ein eindeutiger Jobname Ihrer WahlVERSION
: Die Version der Vorlage, die Sie verwenden möchtenSie können die folgenden Werte verwenden:
latest
zur Verwendung der neuesten Version der Vorlage, die im nicht datierten übergeordneten Ordner im Bucket verfügbar ist: gs://dataflow-templates-REGION_NAME/latest/- Den Versionsnamen wie
2023-09-12-00_RC00
, um eine bestimmte Version der Vorlage zu verwenden. Diese ist verschachtelt im jeweiligen datierten übergeordneten Ordner im Bucket enthalten: gs://dataflow-templates-REGION_NAME/.
REGION_NAME
: die Region, in der Sie Ihren Dataflow-Job bereitstellen möchten, z. B.us-central1
SOURCE_CONFIG_URL
: URL zum Herstellen einer Verbindung zum Quelldatenbankhost. Es kann Folgendes sein: 1. Die JDBC-Verbindungs-URL, die den Host, den Port und den Namen der Quelldatenbank enthalten muss und optional Eigenschaften wie „autoReconnect“ und „maxReconnects“ enthalten kann. Format: `jdbc:mysql://{host}:{port}/{dbName}?{parameters}`2. Der Pfad zur Shard-KonfigurationINSTANCE_ID
: Die Cloud Spanner-Instanz-ID.DATABASE_ID
: die Cloud Spanner-Datenbank-IDPROJECT_ID
: die Cloud Spanner-Projekt-ID.OUTPUT_DIRECTORY
: das Ausgabeverzeichnis für fehlgeschlagene/übersprungene/gefilterte Ereignisse
API
Senden Sie eine HTTP-POST-Anfrage, um die Vorlage mithilfe der REST API auszuführen. Weitere Informationen zur API und ihren Autorisierungsbereichen finden Sie unter projects.templates.launch
.
POST https://dataflow.googleapis.com/v1b3/projects/PROJECT_ID/locations/LOCATION/flexTemplates:launch { "launchParameter": { "jobName": "JOB_NAME", "parameters": { "sourceConfigURL": "SOURCE_CONFIG_URL", "instanceId": "INSTANCE_ID", "databaseId": "DATABASE_ID", "projectId": "PROJECT_ID", "outputDirectory": "OUTPUT_DIRECTORY", }, "containerSpecGcsPath": "gs://dataflow-templates-LOCATION/VERSION/flex/Sourcedb_to_Spanner_Flex", "environment": { "maxWorkers": "10" } } }
Ersetzen Sie Folgendes:
PROJECT_ID
: die ID des Google Cloud-Projekts, in dem Sie den Dataflow-Job ausführen möchtenJOB_NAME
: ein eindeutiger Jobname Ihrer WahlVERSION
: Die Version der Vorlage, die Sie verwenden möchtenSie können die folgenden Werte verwenden:
latest
zur Verwendung der neuesten Version der Vorlage, die im nicht datierten übergeordneten Ordner im Bucket verfügbar ist: gs://dataflow-templates-REGION_NAME/latest/- Den Versionsnamen wie
2023-09-12-00_RC00
, um eine bestimmte Version der Vorlage zu verwenden. Diese ist verschachtelt im jeweiligen datierten übergeordneten Ordner im Bucket enthalten: gs://dataflow-templates-REGION_NAME/.
LOCATION
: die Region, in der Sie Ihren Dataflow-Job bereitstellen möchten, z. B.us-central1
SOURCE_CONFIG_URL
: URL zum Herstellen einer Verbindung zum Quelldatenbankhost. Es kann Folgendes sein: 1. Die JDBC-Verbindungs-URL, die den Host, den Port und den Namen der Quelldatenbank enthalten muss und optional Eigenschaften wie „autoReconnect“ und „maxReconnects“ enthalten kann. Format: `jdbc:mysql://{host}:{port}/{dbName}?{parameters}`2. Der Pfad zur Shard-KonfigurationINSTANCE_ID
: Die Cloud Spanner-Instanz-ID.DATABASE_ID
: die Cloud Spanner-Datenbank-IDPROJECT_ID
: die Cloud Spanner-Projekt-ID.OUTPUT_DIRECTORY
: das Ausgabeverzeichnis für fehlgeschlagene/übersprungene/gefilterte Ereignisse