Get Sink

cloud_logging.get_sink
ActionGoogle Cloudconnection required

Calls GET /projects/{project}/sinks/{sink}.

Read one log export sink, including the writer identity to grant.

Connection

Required
Yes — the node will not save without one
Auth type
OAuth 2.0
Providers
Google Cloud Logging
Secret shape
{"client_id", "client_secret", "refresh_token"}
Config it needs
project_id
Resolved by
config.connection_id, else node.connection_id

Configuration

2 fields, 1 required. A dotted path is a nested object and name[] an array of objects — the editor renders the same tree.

FieldTypeRequiredDefaultConstraintsExample
project_id
GCP project id (overrides connection).
stringNo———
sink_name
Sink id to read.
stringYes———

Output

One shape.

result

FieldTypeExample
name
Sink id.
string—
destination
Where the sink exports to.
string—
filter
Logging filter the sink exports.
string—
disabled
True while the sink is switched off.
boolean—
description
The sink's human description.
string—
writer_identity
Service account the destination must grant write access to.
string—
include_children
True when the sink also exports children of the parent resource.
boolean—
intercept_children
True when child resources' logs are intercepted here.
boolean—
exclusions
Exclusion filters attached to the sink; each one suppresses matching logs.
array—
bigquery_options
BigQuery destination options (partitioned tables).
object—
create_time
When the sink was created.
string—
update_time
When the sink was last changed.
string—
resource_name
Full resource name of the sink, when the API returns one.
string—
{
  "bigquery_options": {},
  "create_time": "",
  "description": "",
  "destination": "",
  "disabled": false,
  "exclusions": [],
  "filter": "",
  "include_children": false,
  "intercept_children": false,
  "name": "",
  "resource_name": "",
  "update_time": "",
  "writer_identity": ""
}

Solutions with Google Cloud Logging

See Get Sink run in a workflow.

In a technical demo we add the Google Cloud Logging connection, drop the node on the canvas and let Workflow Health pre-flight it before the first real run.