Join the Apache Beam community on July 18th-20th for the Beam Summit 2022 to learn more about Beam and share your expertise.

Method: projects.locations.pipelines.create

Creates a pipeline.

For a batch pipeline, you can pass scheduler information. Data Pipelines uses the scheduler information to create an internal scheduler that runs jobs periodically.

If the internal scheduler is not configured, you can use pipelines.run to run jobs.

HTTP request

POST https://datapipelines.googleapis.com/v1/{parent=projects/*/locations/*}/pipelines

The URL uses gRPC Transcoding syntax.

Path parameters

Parameters
parent

string

Required. The location name. For example: projects/PROJECT_ID/locations/LOCATION_ID.

Request body

The request body contains an instance of Pipeline.

Response body

If successful, the response body contains a newly created instance of Pipeline.

Authorization Scopes

Requires the following OAuth scope:

  • https://www.googleapis.com/auth/cloud-platform

For more information, see the Authentication Overview.

IAM Permissions

Requires the following IAM permission on the parent resource:

  • datapipelines.pipelines.create

For more information, see the IAM documentation.