Tutti gli esempi di codice di Dataflow
Questa pagina contiene esempi di codice per Dataflow. Per cercare e filtrare i sample di codice per altri Google Cloud prodotti, consulta il Google Cloud browser di sample.
Leggere da più argomenti Kafka in Dataflow
Mostra come creare una pipeline Dataflow che legga da più argomenti Kafka ed esegua una logica di business diversa in base al nome dell'argomento.
- Dataflow
- Java
- Python
Visualizza i dettagli dell'esecuzione della fase
Mostra come ottenere informazioni sui lavoratori e sugli elementi di lavoro all'interno di una fase.
- Dataflow
- Java
- C#
- Go
- Python
Elenca i job di un progetto in tutte le regioni (asincrona)
Mostra come elencare i job di un progetto in tutte le regioni in modo asincrono.
- Dataflow
- JavaScript
- Python
- Node.js
- C#
- Java
Ottenere i dettagli di esecuzione del job (asincrono)
Mostra come richiedere in modo asincrono informazioni dettagliate sullo stato di esecuzione del job.
- Dataflow
- Python
- Java
- JavaScript
- Node.js
- C#
Utilizzo delle chiavi di crittografia gestite dal cliente
Questo esempio mostra come utilizzare le chiavi di crittografia gestite dal cliente con una pipeline Dataflow.
- Dataflow
- Python
- Java
Eliminare uno snapshot (asincrono)
Mostra come eliminare uno snapshot.
- Dataflow
- C#
- Python
- JavaScript
- Java
- Node.js
Creare un job da un modello (asincrono)
Mostra come creare un job da un modello.
- Dataflow
- Java
- Python
- JavaScript
- Node.js
- C#
Avvia un modello flessibile in modo asincrono
Mostra come avviare un modello flessibile in modo asincrono.
- Dataflow
- Node.js
- Java
- JavaScript
- Python
- C#
Elenca i job di un progetto in tutte le regioni (Ruby)
Mostra come elencare i job di un progetto in tutte le regioni.
- Dataflow
- Ruby
Recupera le metriche del job (asincrone)
Mostra come ottenere una raccolta di metriche che descrivono l'avanzamento dettagliato di un job.
- Dataflow
- Java
- Node.js
- Python
- C#
- JavaScript
Leggi da Apache Iceberg
Utilizza la trasformazione I/O gestita di Dataflow per leggere da Apache Iceberg
- Dataflow
- Java
Lettura con proiezione e filtri
Utilizza il connettore BigQueryIO in modalità DIRECT_READ con la proiezione e il filtro delle colonne.
- Dataflow
- Java
Ottenere i dettagli di esecuzione del job (Ruby)
Richiedi informazioni dettagliate sullo stato di esecuzione del job.
- Dataflow
- Ruby
Aggiornare lo stato di un job esistente
Mostra come aggiornare lo stato di un job esistente.
- Dataflow
- Java
- C#
- Go
- Python
Elenco dei messaggi di job
Mostra come richiedere un elenco di messaggi di job.
- Dataflow
- Java
- Python
- Go
- C#
Recuperare un modello
Mostra come ottenere i metadati e i metadati di runtime di un modello.
- Dataflow
- C#
- Java
- Go
- Ruby
- Python
Leggi da Cloud Storage
Creare una pipeline Dataflow per leggere da un bucket Cloud Storage
- Dataflow
- Java
Leggere da Apache Kafka in Dataflow
Mostra come creare una pipeline Dataflow che legga da Apache Kafka
- Dataflow
- Java
- Python
Leggere in oggetti TableRow
Utilizza il connettore BigQueryIO per leggere gli oggetti TableRow.
- Dataflow
- Java
Elenca job (asincrono)
Mostra come elencare i job in modo asincrono.
- Dataflow
- Python
- Node.js
- C#
- Java
- JavaScript
Ottenere i dettagli dell'esecuzione della fase (Ruby)
Mostra come ottenere informazioni sui lavoratori e sugli elementi di lavoro all'interno di una fase.
- Dataflow
- Ruby
Scrivere in BigQuery utilizzando uno schema di tabella
Scrivere da Dataflow in una tabella BigQuery nuova o esistente, fornendo uno schema della tabella
- Dataflow
- Java
Scrivere in Apache Iceberg
Utilizza la trasformazione I/O gestita di Dataflow per scrivere in Apache Iceberg
- Dataflow
- Java
Elenca i job di un progetto in tutte le regioni
Mostra come elencare i job di un progetto in tutte le regioni.
- Dataflow
- C#
- Python
- Go
- Java
Controlla se esistono job attivi per un progetto (asincrono)
Mostra come verificare in modo asincrono se esistono job attivi per un progetto.
- Dataflow
- JavaScript
- Node.js
- Python
- C#
- Java
Acquisisci uno snapshot dello stato di un job di flusso (Ruby)
Mostra come acquisire uno snapshot dello stato di un job in streaming.
- Dataflow
- Ruby
Visualizzare i dettagli di esecuzione del job
Mostra come richiedere informazioni dettagliate sullo stato di esecuzione del job.
- Dataflow
- C#
- Go
- Python
- Java
Scrivere messaggi con attributi personalizzati in Pub/Sub
Utilizzare Dataflow per scrivere messaggi con attributi personalizzati in Pub/Sub
- Dataflow
- Python
- Java
Recuperare lo stato di un job in modo asincrono
Mostra come recuperare lo stato di un job specificato in modo asincrono.
- Dataflow
- JavaScript
- Java
- Python
- Node.js
- C#
Recupera un modello (asincrono)
Mostra come ottenere i metadati e i metadati di runtime di un modello.
- Dataflow
- C#
- Java
- JavaScript
- Python
- Node.js
Trasmetti in streaming a BigQuery con l'elaborazione exactly-once
Utilizzare l'API Storage Write per trasmettere in streaming da Dataflow a BigQuery con elaborazione esattamente una volta
- Dataflow
- Java
Eseguire un modello
Questo esempio mostra l'esecuzione di base di un modello Dataflow in base al nome del job e al percorso del modello.
- Dataflow
- Python
Visualizza le metriche del job
Mostra come ottenere una raccolta di metriche che descrivono l'avanzamento di un job.
- Dataflow
- Go
- Python
- Java
- C#
Recuperare uno snapshot (asincrono)
Mostra come ottenere un'istantanea.
- Dataflow
- Java
- JavaScript
- Node.js
- Python
- C#
Ottenere le metriche del job (Ruby)
Mostra come ottenere una raccolta di metriche che descrivono l'avanzamento di un job.
- Dataflow
- Ruby
Verificare se esistono job attivi per un progetto
Mostra come verificare se esistono job attivi per un progetto.
- Dataflow
- C#
- Python
- Java
- Go
Verificare se esistono job attivi per un progetto (Ruby)
Mostra come verificare se esistono job attivi per un progetto.
- Dataflow
- Ruby
Creare un job in modo asincrono
Mostra come creare un job in modo asincrono.
- Dataflow
- Python
- Java
- C#
- Node.js
- JavaScript
Leggere da una query
Utilizza il connettore BigQueryIO per leggere da un risultato della query.
- Dataflow
- Java
Output di testo in Cloud Storage
Utilizza il connettore TextIO per scrivere file di testo in un bucket Cloud Storage.
- Dataflow
- Python
- Java
Elenca i messaggi del job (asincrono)
Mostra come richiedere un elenco di messaggi di job in modo asincrono.
- Dataflow
- Java
- JavaScript
- C#
- Node.js
- Python
Acquisisci uno snapshot dello stato di un job di flusso (asincrono)
Mostra come acquisire uno snapshot dello stato di un job di streaming in modo asincrono.
- Dataflow
- JavaScript
- Node.js
- C#
- Java
- Python
Recupera i dettagli dell'esecuzione della fase (asincrona)
Mostra come ottenere informazioni sui lavoratori e sugli elementi di lavoro all'interno di una fase.
- Dataflow
- JavaScript
- Python
- Java
- Node.js
- C#
Acquisisci uno snapshot dello stato di un job di flusso
Mostra come acquisire uno snapshot dello stato di un job in streaming.
- Dataflow
- Go
- Java
- C#
- Python
Aggiornare lo stato di un job esistente (asincrono)
Mostra come aggiornare lo stato di un job esistente in modo asincrono.
- Dataflow
- Java
- Python
- C#
- Node.js
- JavaScript
Elenca gli snapshot (asincrono)
Mostra come elencare gli snapshot.
- Dataflow
- JavaScript
- Python
- Java
- Node.js
- C#