Googleapis Datapipelines
googleapis-datapipelines is a generated connector for Google Cloud Data Pipelines, a service for creating and managing scheduled data pipeline jobs.
- Base URL:
https://datapipelines.googleapis.com - Auth: OAuth 2.0 (user-delegated) — attach an InTouch
oauthcredential. Mint one withitcli.py /oauth <provider>(device-code) or/google-auth(Google); the server auto-refreshes the access token before each run, so the connector never handles or stores tokens.
Operations
datapipelines_projects_locations_pipelines_get— GET /v1/{name} — Looks up a single pipeline. Returns a "NOT_FOUND" error if no such pipeline exisdatapipelines_projects_locations_pipelines_jobs_— GET /v1/{parent}/jobs — Lists jobs for a given pipeline. Throws a "FORBIDDEN" error if the caller doesn'datapipelines_projects_locations_pipelines_list— GET /v1/{parent}/pipelines — Lists pipelines. Returns a "FORBIDDEN" error if the caller doesn't have permissidatapipelines_projects_locations_pipelines_delet— DELETE /v1/{name} — Deletes a pipeline. If a scheduler job is attached to the pipeline, it will be ddatapipelines_projects_locations_pipelines_patch— PATCH /v1/{name} — Updates a pipeline. If successful, the updated Pipeline is returned. Returns `NOdatapipelines_projects_locations_pipelines_run— POST /v1/{name}:run — Creates a job for the specified pipeline directly. You can use this method when
Inputs
- a linked
oauthcredential (no key inputs) — the server injects a freshAuthorization: Bearerfrom it operation— one of the operations above- path parameters when an operation's path contains
{...} query— optional JSON object of query paramsbody— JSON object for create/update ops
Example
operation: datapipelines_projects_locations_pipelines_get
# (attach an 'oauth' credential to the task — no inline secrets)
Publishes
The keys a later task may reference as {{taskName.key}}. Referencing anything not listed here resolves to nothing at run time.
erroroperationresultstatus
Input Properties
Every property this tool accepts, from its own tool.iml.
| Property | Type | Required | Default | Description |
|---|---|---|---|---|
operation |
string | yes | — | One of: datapipelines_projects_locations_pipelines_get, datapipelines_projects_locations_pipelines_jobs_, datapipelines_projects_locations_pipelines_list, datapipelines_projects_locations_pipelines_delet, datapipelines_projects_locations_pipelines_patch, datapipelines_projects_locations_pipelines_run |
name |
string | no | — | Path parameter name (required by some operations). |
parent |
string | no | — | Path parameter parent (required by some operations). |
query |
string | no | — | Optional query params as a JSON object string, e.g. {"limit": 10}. |
body |
string | no | — | Request body as a JSON object string (for create/update operations). |