すべての 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.

C# Go Java Python

View sample

Check if active jobs exist for a project (async)

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

C# Java 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.

C# Go Java 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.

C# Java Node.js Python

View sample

Create a job from a template

Demonstrates how to create a job from a template.

C# Go Java Python Ruby

View sample

Create a job from a template (async)

Demonstrates how to create a job from a template.

C# Java Node.js Python

View sample

Delete a snapshot

Demonstrates how to delete a snapshot.

C# Go Java Python

View sample

Delete a snapshot (async)

Demonstrates how to delete a snapshot.

C# Java 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.

C# Go Java Python

View sample

Get a snapshot (async)

Demonstrates how to get a snapshot.

C# Java 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.

C# Go Java Python Ruby

View sample

Get a template (async)

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

C# Java Node.js Python

View sample

Get job execution details

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

C# Go Java Python

View sample

Get job execution details (async)

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

C# Java 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.

C# Go Java Python

View sample

Get job metrics (async)

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

C# Java 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.

C# Go Java Python

View sample

Get stage execution details (async)

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

C# Java 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.

C# Go Java 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.

C# Java Node.js Python

View sample

Launch a Flex Template

Demonstrates how to launch a Flex Template.

C# Go Java Python Ruby

View sample

Launch a Flex Template asynchronously

Demonstrates how to launch a Flex Template asynchronously.

C# Java Node.js Python

View sample

Launch a template

Demonstrates how to launch a template.

C# Go Java Python Ruby

View sample

Launch a template (async)

Demonstrates how to launch a template.

C# Java Node.js Python

View sample

List job messages

Demonstrates how to request a list of job messages.

C# Go Java Python

View sample

List job messages (async)

Demonstrates how to request a list of job messages asynchronously.

C# Java 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.

C# Go Java Python

View sample

List jobs (async)

Demonstrates how to list jobs asynchronously.

C# Java Node.js Python

View sample

List jobs (Ruby)

Demonstrates how to list jobs.

Ruby

View sample

List snapshots

Demonstrates how to list snapshots.

C# Go Java Python

View sample

List snapshots (async)

Demonstrates how to list snapshots.

C# Java 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.

C# Go Java 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.

C# Java 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.

C# Go Java Python

View sample

Snapshot the state of a streaming job (async)

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

C# Java 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.

C# Go Java Python

View sample

Update the state of an existing job (async)

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

C# Java 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