Alle Dataflow-Codebeispiele
Diese Seite enthält Codebeispiele für Dataflow. Informationen zum Suchen und Filtern von Codebeispielen für andere Google Cloud -Produkte finden Sie im Google Cloud -Beispielbrowser.
Mit genau einmaliger Verarbeitung an BigQuery streamen
Storage Write API zum Streamen von Dataflow zu BigQuery mit genau einmaliger Verarbeitung verwenden
- Dataflow
- Java
Jobnachrichten auflisten (Ruby)
Zeigt, wie eine Liste der Jobnachrichten angefordert wird.
- Dataflow
- Ruby
Job aus einer Vorlage erstellen
Zeigt, wie ein Job aus einer Vorlage erstellt wird.
- Dataflow
- Ruby
- Go
- C#
- Java
- Python
Jobmesswerte (Ruby) abrufen
Zeigt, wie eine Sammlung von Messwerten abgerufen wird, die den detaillierten Fortschritt eines Jobs beschreiben.
- Dataflow
- Ruby
Auf aktive Jobs für ein Projekt prüfen
Demonstriert, wie geprüft wird, ob aktive Jobs für ein Projekt vorhanden sind.
- Dataflow
- Java
- Python
- Go
- C#
Jobmesswerte abrufen
Zeigt, wie eine Sammlung von Messwerten abgerufen wird, die den detaillierten Fortschritt eines Jobs beschreiben.
- Dataflow
- Java
- C#
- Go
- Python
Snapshot abrufen (async)
Zeigt, wie ein Snapshot abgerufen wird.
- Dataflow
- Python
- Java
- C#
- JavaScript
- Node.js
Snapshot des Status eines Streamingjobs erstellen
Zeigt, wie ein Snapshot vom Status eines Streamingjobs erstellt wird.
- Dataflow
- Go
- C#
- Java
- Python
Auf aktive Jobs für ein Projekt prüfen (Ruby)
Demonstriert, wie geprüft wird, ob aktive Jobs für ein Projekt vorhanden sind.
- Dataflow
- Ruby
Job asynchron erstellen
Zeigt, wie ein Job asynchron erstellt wird.
- Dataflow
- C#
- Node.js
- Java
- JavaScript
- Python
Jobnachrichten auflisten (asynchron)
Zeigt, wie Sie eine Liste von Jobnachrichten asynchron anfordern.
- Dataflow
- Python
- Java
- C#
- Node.js
- JavaScript
Text in Cloud Storage ausgeben
Mit dem TextIO-Connector Textdateien in einen Cloud Storage-Bucket schreiben
- Dataflow
- Java
- Python
Details zur Phasenausführung abrufen (asynchron)
Zeigt, wie Informationen zu den Workern und Arbeitselementen in einer Phase abgerufen werden.
- Dataflow
- Python
- Node.js
- Java
- C#
- JavaScript
Snapshot des Status eines Streamingjobs erstellen (asynchron)
Zeigt, wie ein Snapshot vom Status eines Streamingjobs asynchron erstellt wird.
- Dataflow
- Python
- JavaScript
- C#
- Node.js
- Java
Vorlage ausführen
Dieses Beispiel zeigt die einfache Ausführung einer Dataflow-Vorlage nach Jobname und Vorlagenpfad.
- Dataflow
- Python
Snapshots auflisten (asynchron)
Zeigt, wie Snapshots aufgelistet werden.
- Dataflow
- Python
- JavaScript
- Node.js
- C#
- Java
Zustand eines vorhandenen Jobs aktualisieren (asynchron)
Zeigt, wie der Status eines vorhandenen Jobs asynchron aktualisiert wird.
- Dataflow
- Node.js
- Java
- Python
- JavaScript
- C#
Aus einer Abfrage lesen
Verwenden Sie den BigQueryIO-Connector, um aus einem Abfrageergebnis zu lesen.
- Dataflow
- Java
Avro-Format lesen
Verwenden Sie den BigQueryIO-Connector, um Daten im Avro-Format einzulesen.
- Dataflow
- Java
Details zur Jobausführung abrufen
Zeigt, wie Sie detaillierte Informationen zum Ausführungsstatus des Jobs anfordern.
- Dataflow
- C#
- Java
- Go
- Python
Nachrichten mit benutzerdefinierten Attributen in Pub/Sub schreiben
Dataflow verwenden, um Nachrichten mit benutzerdefinierten Attributen in Pub/Sub zu schreiben
- Dataflow
- Java
- Python
In Apache Iceberg schreiben
Mit der von Dataflow verwalteten E/A-Transformation in Apache Iceberg schreiben
- Dataflow
- Java
Snapshot eines Status eines Streamingjobs erstellen (Ruby)
Zeigt, wie ein Snapshot vom Status eines Streamingjobs erstellt wird.
- Dataflow
- Ruby
Vorlage abrufen (asynchron)
Zeigt, wie Metadaten und Laufzeitmetadaten zu einer Vorlage abgerufen werden.
- Dataflow
- Node.js
- C#
- Java
- Python
- JavaScript
Status eines Jobs asynchron abrufen
Zeigt, wie der Status eines bestimmten Jobs asynchron abgerufen wird.
- Dataflow
- Java
- C#
- JavaScript
- Python
- Node.js
Jobs auflisten (asynchron)
Zeigt, wie Jobs asynchron aufgelistet werden.
- Dataflow
- Node.js
- C#
- JavaScript
- Java
- Python
Details zur Phasenausführung abrufen (Ruby)
Zeigt, wie Informationen zu den Workern und Arbeitselementen in einer Phase abgerufen werden.
- Dataflow
- Ruby
Mit einem Tabellenschema in BigQuery schreiben
Schreiben Sie von Dataflow in eine neue oder vorhandene BigQuery-Tabelle. Geben Sie dazu ein Tabellenschema an.
- Dataflow
- Java
Jobs eines Projekts in allen Regionen auflisten (Ruby)
Zeigt, wie die Jobs eines Projekts in allen Regionen aufgelistet werden.
- Dataflow
- C#
- Java
- Go
- Python
Auf aktive Jobs für ein Projekt prüfen (asynchron)
Demonstriert, wie asynchron geprüft wird, ob aktive Jobs für ein Projekt vorhanden sind.
- Dataflow
- C#
- JavaScript
- Python
- Node.js
- Java
Job aus einer Vorlage erstellen (asynchron)
Zeigt, wie ein Job aus einer Vorlage erstellt wird.
- Dataflow
- JavaScript
- Python
- C#
- Java
- Node.js
Aus Apache Kafka in Dataflow lesen
Eine Dataflow-Pipeline erstellen, die Daten aus Apache Kafka liest
- Dataflow
- Python
- Java
Jobs eines Projekts in allen Regionen auflisten (Ruby)
Zeigt, wie die Jobs eines Projekts in allen Regionen aufgelistet werden.
- Dataflow
- Ruby
Zustand eines vorhandenen Jobs aktualisieren
Zeigt, wie der Status eines vorhandenen Jobs aktualisiert wird.
- Dataflow
- C#
- Python
- Java
- Go
Kundenverwaltete Verschlüsselungsschlüssel verwenden
Dieses Beispiel zeigt, wie vom Kunden verwaltete Verschlüsselungsschlüssel mit einer Dataflow-Pipeline verwendet werden.
- Dataflow
- Java
- Python
Details zur Phasenausführung abrufen
Zeigt, wie Informationen zu den Workern und Arbeitselementen in einer Phase abgerufen werden.
- Dataflow
- Python
- C#
- Go
- Java
Jobmesswerte abrufen (asynchron)
Zeigt, wie eine Sammlung von Messwerten abgerufen wird, die den detaillierten Fortschritt eines Jobs beschreiben.
- Dataflow
- C#
- Python
- Java
- Node.js
- JavaScript
Jobs eines Projekts in allen Regionen auflisten (asynchron)
Zeigt, wie Jobs eines Projekts in allen Regionen asynchron aufgelistet werden.
- Dataflow
- Python
- Node.js
- C#
- Java
- JavaScript
Jobnachrichten auflisten
Zeigt, wie eine Liste der Jobnachrichten angefordert wird.
- Dataflow
- Python
- C#
- Go
- Java
Details zur Jobausführung abrufen (Ruby)
Fordern Sie detaillierte Informationen zum Ausführungsstatus des Jobs an.
- Dataflow
- Ruby
Details zur Jobausführung abrufen (asynchron)
Zeigt, wie Sie detaillierte Informationen zum Ausführungsstatus des Jobs asynchron anfordern.
- Dataflow
- JavaScript
- Python
- Node.js
- C#
- Java
Snapshot löschen (asynchron)
Veranschaulicht, wie ein Snapshot gelöscht wird.
- Dataflow
- Node.js
- Python
- C#
- Java
- JavaScript
Daten aus mehreren Kafka-Topics in Dataflow lesen
Hier erfahren Sie, wie Sie eine Dataflow-Pipeline erstellen, die aus mehreren Kafka-Themen liest und je nach Themenname unterschiedliche Geschäftslogiken ausführt.
- Dataflow
- Java
- Python
Aus Cloud Storage lesen
Dataflow-Pipeline zum Lesen aus einem Cloud Storage-Bucket erstellen
- Dataflow
- Java
Flexible Vorlage asynchron starten
Zeigt, wie eine flexible Vorlage asynchron gestartet wird.
- Dataflow
- C#
- JavaScript
- Java
- Python
- Node.js
Mit Projektion und Filterung lesen
Verwenden Sie den BigQueryIO-Connector im Modus „DIRECT_READ“ mit Spaltenprojektion und ‑filterung.
- Dataflow
- Java
Vorlage abrufen
Zeigt, wie Metadaten und Laufzeitmetadaten zu einer Vorlage abgerufen werden.
- Dataflow
- Ruby
- Java
- Python
- Go
- C#
Aus Apache Iceberg lesen
Mit der von Dataflow verwalteten E/A-Transformation aus Apache Iceberg lesen
- Dataflow
- Java
Vorlage starten (asynchron)
Zeigt, wie eine Vorlage gestartet wird.
- Dataflow
- Java
- C#
- Python
- Node.js
- JavaScript
In TableRow-Objekte einlesen
Verwenden Sie den BigQueryIO-Connector, um Daten in TableRow-Objekte zu lesen.
- Dataflow
- Java