Tendrl

Docs / Strand / connectors/gcp-pubsub

Google Pub/Sub

Direction: Read / Write | Type: gcp.pubsub

Google Cloud Pub/Sub connector for publishing messages to topics and receiving messages from subscriptions.

Required Permissions#

The service account must have the following IAM permissions (or predefined roles):

Operation Required Permissions Predefined Role
publish pubsub.topics.publish Pub/Sub Publisher
subscribe pubsub.subscriptions.consume Pub/Sub Subscriber
Tip: Grant roles at the topic or subscription level for least privilege rather than at the project level.

Operations#

Operation Direction Description
publish Write Publish a message to a topic
subscribe Read Receive a message from a subscription

Connector Configuration#

Field Required Default Description
Authentication Type No api_key Uses explicit credentials (the fields below).
Project ID Yes - Google Cloud project ID
Credentials JSON Conditional - Service account JSON credentials (encrypted). Required when Authentication Type is api_key
Topic Name No - Default topic name (can be overridden at node level)
Subscription Name No - Default subscription name (can be overridden at node level)

Node Configuration#

Field Required Description
Operation Yes publish or subscribe
Topic Name No Pub/Sub topic name (for publish)
Subscription Name No Subscription name (for subscribe)

Output#

publish#

json

{
  "success": true,
  "status": "sent",
  "data": {
    "message_id": "123456789",
    "topic": "my-topic"
  },
  "service": "gcp.pubsub",
  "operation": "publish"
}

subscribe#

json

{
  "success": true,
  "status": "received",
  "data": {
    "subscription": "my-subscription",
    "message": {"key": "value"}
  },
  "service": "gcp.pubsub",
  "operation": "subscribe"
}

When no messages are available:

json

{
  "success": true,
  "status": "empty",
  "data": {
    "subscription": "my-subscription",
    "message": null
  },
  "service": "gcp.pubsub",
  "operation": "subscribe"
}

Example#

Connector Setup:

json

{
  "project_id": "my-gcp-project",
  "credentials_json": "{...service account JSON...}",
  "topic_name": "order-events",
  "subscription_name": "order-processor"
}

Node Configuration (publish):

Node Configuration (subscribe):

← Back to Strand docs