すべての Dataflow コードサンプル

This page contains code samples for Dataflow. To search and filter code samples for other Google Cloud products, see the Google Cloud sample browser.

Check if active jobs exist for a project

Demonstrates how to check if active jobs exist for a project.

Go Python

View sample

Check if active jobs exist for a project (async)

Demonstrates how to check asynchronously if active jobs exist for a project.

Node.js Python

View sample

Check if active jobs exist for a project (Ruby)

Demonstrates how to check if active jobs exist for a project.

Ruby

View sample

Create a job

Demonstrates how to create a job.

Go Python

View sample

Create a job (Ruby)

Demonstrates how to create a job.

Ruby

View sample

Create a job asynchronously

Demonstrates how to create a job asynchronously.

Node.js Python

View sample

Create a job from a template

Demonstrates how to create a job from a template.

Go Python Ruby

View sample

Create a job from a template (async)

Demonstrates how to create a job from a template.

Node.js Python

View sample

Delete a snapshot

Demonstrates how to delete a snapshot.

Go Python

View sample

Delete a snapshot (async)

Demonstrates how to delete a snapshot.

Node.js Python

View sample

Delete a snapshot (Ruby)

Demonstrates how to delete a snapshot.

Ruby

View sample

Get a snapshot

Demonstrates how to get a snapshot.

Go Python

View sample

Get a snapshot (async)

Demonstrates how to get a snapshot.

Node.js Python

View sample

Get a snapshot (Ruby)

Demonstrates how to get a snapshot.

Ruby

View sample

Get a template

Demonstrates how to get metadata and runtime metadata about a template.

Go Python Ruby

View sample

Get a template (async)

Demonstrates how to get metadata and runtime metadata about a template.

Node.js Python

View sample

Get job execution details

Demonstrates how to request detailed information about the execution status of the job.

Go Python

View sample

Get job execution details (async)

Demonstrates how to asynchronously request detailed information about the execution status of the job.

Node.js Python

View sample

Get job execution details (Ruby)

Request detailed information about the execution status of the job.

Ruby

View sample

Get job metrics

Demonstrates how to get a collection of metrics describing the progress of a job.

Go Python

View sample

Get job metrics (async)

Demonstrates how to get a collection of metrics describing the detailed progress of a job.

Node.js Python

View sample

Get job metrics (Ruby)

Demonstrates how to get a collection of metrics describing the progress of a job.

Ruby

View sample

Get stage execution details

Demonstrates how to get information about the workers and work items within a stage.

Go Python

View sample

Get stage execution details (async)

Demonstrates how to get information about the workers and work items within a stage.

Node.js Python

View sample

Get stage execution details (Ruby)

Demonstrates how to get information about the workers and work items within a stage.

Ruby

View sample

Get the state of a job

Demonstrates how to get the state of a job.

Go Python

View sample

Get the state of a job (Ruby)

Demonstrates how to get the state of a job.

Ruby

View sample

Get the state of a job asynchronously

Demonstrates how to get the state of a specified job asynchronously.

Node.js Python

View sample

Launch a Flex Template

Demonstrates how to launch a Flex Template.

Go Python Ruby

View sample

Launch a Flex Template asynchronously

Demonstrates how to launch a Flex Template asynchronously.

Node.js Python

View sample

Launch a template

Demonstrates how to launch a template.

Go Python Ruby

View sample

Launch a template (async)

Demonstrates how to launch a template.

Node.js Python

View sample

List job messages

Demonstrates how to request a list of job messages.

Go Python

View sample

List job messages (async)

Demonstrates how to request a list of job messages asynchronously.

Node.js Python

View sample

List job messages (Ruby)

Demonstrates how to request a list of job messages.

Ruby

View sample

List jobs

Demonstrates how to list jobs.

Go Python

View sample

List jobs (async)

Demonstrates how to list jobs asynchronously.

Node.js Python

View sample

List jobs (Ruby)

Demonstrates how to list jobs.

Ruby

View sample

List snapshots

Demonstrates how to list snapshots.

Go Python

View sample

List snapshots (async)

Demonstrates how to list snapshots.

Node.js Python

View sample

List snapshots (Ruby)

Demonstrates how to list snapshots.

Ruby

View sample

List the jobs of a project across all regions

Demonstrates how to list the jobs of a project across all regions.

Go Python

View sample

List the jobs of a project across all regions (async)

Demonstrates how to list the jobs of a project across all regions, asynchronously.

Node.js Python

View sample

List the jobs of a project across all regions (Ruby)

Demonstrates how to list the jobs of a project across all regions.

Ruby

View sample

Run a template

This sample demonstrates basic execution of a Dataflow template by job name and template path.

Python

View sample

View in documentation

• Running classic templates

Snapshot the state of a streaming job

Demonstrates how to snapshot the state of a streaming job.

Go Python

View sample

Snapshot the state of a streaming job (async)

Demonstrates how to snapshot the state of a streaming job asynchronously.

Node.js Python

View sample

Snapshot the state of a streaming job (Ruby)

Demonstrates how to snapshot the state of a streaming job.

Ruby

View sample

Update a job (Ruby)

Demonstrates how to update the state of an existing job.

Ruby

View sample

Update the state of an existing job

Demonstrates how to update the state of an existing job.

Go Python

View sample

Update the state of an existing job (async)

Demonstrates how to update the state of an existing job asynchronously.

Node.js Python

View sample

Use customer-managed encryption keys

This sample shows how to use encryption keys managed by the customer, with a Dataflow pipeline.

Java Python

View sample