Mira las muestras de código.
Esta página contiene muestras de código para Dataflow. Para buscar y filtrar muestras de código para otros productos de Google Cloud , consulta el navegador de muestras deGoogle Cloud .
Crea un trabajo a partir de una plantilla
Demuestra cómo crear un trabajo a partir de una plantilla.
- Dataflow
- C#
- Ruby
- Java
- Go
- Python
Transmite a BigQuery con procesamiento de tipo “exactamente una vez”
Usa la API de Storage Write para transmitir de Dataflow a BigQuery con procesamiento del tipo “exactamente una vez”
- Dataflow
- Java
Muestra mensajes de trabajos (Ruby)
Demuestra cómo solicitar una lista de mensajes de trabajos.
- Dataflow
- Ruby
Obtén detalles de la ejecución de una etapa (asíncrono)
Demuestra cómo obtener información sobre los trabajadores y los elementos de trabajo dentro de una etapa.
- Dataflow
- C#
- Node.js
- JavaScript
- Java
- Python
Texto de salida a Cloud Storage
Usa el conector de TextIO para escribir archivos de texto en un bucket de Cloud Storage.
- Dataflow
- Python
- Java
Haz una instantánea del estado de un trabajo de transmisión
Demuestra cómo realizar una instantánea del estado de un trabajo de transmisión.
- Dataflow
- Java
- Python
- C#
- Go
Enumera mensajes de trabajos (asíncrono)
Demuestra cómo solicitar una lista de mensajes de trabajos de forma asíncrona.
- Dataflow
- C#
- JavaScript
- Python
- Node.js
- Java
Obtén métricas de un trabajo (Ruby)
Demuestra cómo obtener una colección de métricas que describen el progreso de un trabajo.
- Dataflow
- Ruby
Crea un trabajo de forma asíncrona
Demuestra cómo crear un trabajo de forma asíncrona.
- Dataflow
- Node.js
- JavaScript
- C#
- Java
- Python
Lee desde una consulta
Usa el conector de BigQueryIO para leer desde el resultado de una consulta.
- Dataflow
- Java
Actualiza el estado de un trabajo existente (asíncrono)
Demuestra cómo actualizar el estado de un trabajo existente de forma asíncrona.
- Dataflow
- Node.js
- JavaScript
- C#
- Python
- Java
Obtén una instantánea (asíncrona)
Demuestra cómo obtener una instantánea.
- Dataflow
- C#
- JavaScript
- Node.js
- Java
- Python
Verifica si existen trabajos activos en un proyecto (Ruby)
Demuestra cómo verificar si los trabajos activos existen para un proyecto.
- Dataflow
- Ruby
Ejecuta una plantilla
En este ejemplo, se muestra la ejecución básica de una plantilla de Dataflow por nombre de trabajo y ruta de plantilla.
- Dataflow
- Python
Enumera instantáneas (asíncrono)
Demuestra cómo enumerar instantáneas.
- Dataflow
- JavaScript
- C#
- Node.js
- Java
- Python
Obtén métricas de trabajo
Demuestra cómo obtener una colección de métricas que describen el progreso de un trabajo.
- Dataflow
- C#
- Python
- Java
- Go
Verifica si existen trabajos activos en un proyecto
Demuestra cómo verificar si los trabajos activos existen para un proyecto.
- Dataflow
- Java
- C#
- Python
- Go
Haz una instantánea del estado de un trabajo de transmisión (asíncrono)
Demuestra cómo realizar una instantánea del estado de un trabajo de transmisión de manera asíncrona.
- Dataflow
- Java
- C#
- Node.js
- JavaScript
- Python
Lee desde varios temas de Kafka en Dataflow
Muestra cómo crear una canalización de Dataflow que lea desde varios temas de Kafka y realiza una lógica empresarial diferente según el nombre del tema.
- Dataflow
- Java
- Python
Lee con proyección y filtrado
Usa el conector de BigQueryIO en el modo DIRECT_READ con proyección y filtrado de columnas.
- Dataflow
- Java
Inicia una plantilla flexible de forma asíncrona
Muestra cómo iniciar una plantilla flexible de forma asíncrona.
- Dataflow
- Java
- Python
- Node.js
- JavaScript
- C#
Enumera los trabajos de un proyecto en todas las regiones (Ruby)
Demuestra cómo enumerar los trabajos de un proyecto en todas las regiones.
- Dataflow
- Ruby
Enumera mensajes de trabajos
Demuestra cómo solicitar una lista de mensajes de trabajos.
- Dataflow
- Java
- C#
- Go
- Python
Borra una instantánea (asíncrono)
Demuestra cómo borrar una instantánea.
- Dataflow
- Node.js
- C#
- JavaScript
- Java
- Python
Obtén detalles de la ejecución de trabajos (asíncrono)
Demuestra cómo solicitar de forma asíncrona información detallada sobre el estado de ejecución del trabajo.
- Dataflow
- C#
- Python
- Java
- JavaScript
- Node.js
Inicia una plantilla (asíncrono)
Demuestra cómo iniciar una plantilla.
- Dataflow
- C#
- Python
- JavaScript
- Java
- Node.js
Obtén métricas de trabajos (asíncrono)
Demuestra cómo obtener una colección de métricas que describen el progreso detallado de un trabajo.
- Dataflow
- Java
- Node.js
- JavaScript
- Python
- C#
Obtén detalles de la ejecución de una etapa
Demuestra cómo obtener información sobre los trabajadores y los elementos de trabajo dentro de una etapa.
- Dataflow
- C#
- Java
- Go
- Python
Obtén una plantilla
Demuestra cómo obtener metadatos y metadatos de entorno de ejecución sobre una plantilla.
- Dataflow
- Python
- Java
- Ruby
- Go
- C#
Lee desde Cloud Storage
Crea una canalización de Dataflow para leer desde un bucket de Cloud Storage
- Dataflow
- Java
Obtén detalles de la ejecución de un trabajo (Ruby)
Solicita información detallada sobre el estado de ejecución del trabajo.
- Dataflow
- Ruby
Usar claves de encriptación administradas por el cliente
En este ejemplo, se muestra cómo usar claves de encriptación administradas por el cliente con una canalización de Dataflow.
- Dataflow
- Java
- Python
Lee desde Apache Kafka a Dataflow
Muestra cómo crear una canalización de Dataflow que lea desde Apache Kafka
- Dataflow
- Python
- Java
Enumera los trabajos de un proyecto en todas las regiones (asíncrono)
Demuestra cómo enumerar los trabajos de un proyecto en todas las regiones de manera asíncrona.
- Dataflow
- C#
- Node.js
- Python
- Java
- JavaScript
Crea un trabajo a partir de una plantilla (asíncrono)
Demuestra cómo crear un trabajo a partir de una plantilla.
- Dataflow
- Python
- Node.js
- Java
- JavaScript
- C#
Actualiza el estado de un trabajo existente
Demuestra cómo actualizar el estado de un trabajo existente.
- Dataflow
- Go
- Python
- Java
- C#
Leer desde Apache Iceberg
Usa la transformación de E/S administrada de Dataflow para leer desde Apache Iceberg
- Dataflow
- Java
Obtén detalles de la ejecución de un trabajo
Demuestra cómo solicitar información detallada sobre el estado de ejecución del trabajo.
- Dataflow
- Java
- Python
- C#
- Go
Obtén una plantilla (asíncrono)
Demuestra cómo obtener metadatos y metadatos de entorno de ejecución sobre una plantilla.
- Dataflow
- Java
- Python
- Node.js
- C#
- JavaScript
Obtén el estado de un trabajo de manera asíncrona
Demuestra cómo obtener de manera asíncrona el estado de un trabajo especificado.
- Dataflow
- JavaScript
- Node.js
- Python
- Java
- C#
Enumera trabajos (asíncrono)
Demuestra cómo enumerar trabajos de forma asíncrona.
- Dataflow
- JavaScript
- Python
- Node.js
- Java
- C#
Escribir en BigQuery con un esquema de tabla
Proporciona un esquema de tabla para escribir desde Dataflow a una tabla de BigQuery nueva o existente.
- Dataflow
- Java
Obtén detalles de la ejecución de la etapa (Ruby)
Demuestra cómo obtener información sobre los trabajadores y los elementos de trabajo dentro de una etapa.
- Dataflow
- Ruby
Verifica si existen trabajos activos en un proyecto (asíncrono)
Demuestra cómo verificar de forma asíncrona si los trabajos activos existen para un proyecto.
- Dataflow
- C#
- Node.js
- Python
- Java
- JavaScript
Haz una instantánea del estado de un trabajo de transmisión (Ruby)
Demuestra cómo realizar una instantánea del estado de un trabajo de transmisión.
- Dataflow
- Ruby
Escribe mensajes con atributos personalizados en Pub/Sub
Usa Dataflow para escribir mensajes con atributos personalizados en Pub/Sub
- Dataflow
- Python
- Java
Escribe en Apache Iceberg
Usa la transformación de E/S administrada de Dataflow para escribir en Apache Iceberg
- Dataflow
- Java
Enumera los trabajos de un proyecto en todas las regiones
Demuestra cómo enumerar los trabajos de un proyecto en todas las regiones.
- Dataflow
- Java
- Python
- Go
- C#