Google Pub/Sub Nodes
Google Cloud Pub/Sub is a fully managed, real-time messaging service used for event streaming, microservice communication, and data pipeline ingestion. MaestroHub provides a Publish node so you can send messages to Pub/Sub topics within your pipelines.
Configuration Quick Reference
| Field | What you choose | Details |
|---|---|---|
| Parameters | Connection, Function, Function Parameters, Timeout Override | Select the connection profile, function, configure function parameters with expression support, and optionally override timeout. |
| Settings | Description, Timeout (seconds), Retry on Timeout, Retry on Fail, On Error | Node description, maximum execution time, retry behavior on timeout or failure, and error handling strategy. All execution settings default to pipeline-level values. |
Google Pub/Sub Publish Node
Google Pub/Sub Publish Node
Publish messages to Google Pub/Sub topics with support for ordering keys, custom attributes, and dynamic payload templates.
Supported Function Types:
| Function Name | Purpose | Common Use Cases |
|---|---|---|
| Publish | Send messages to a Pub/Sub topic with configurable payload, ordering key, and attributes | Event broadcasting, IoT telemetry streaming, cross-service notifications, data pipeline ingestion |
How It Works
When the pipeline executes, the Publish node:
- Connects to Google Cloud Pub/Sub using the selected connection profile
- Serializes the message payload (JSON or text) with the configured ordering key and attributes
- Publishes the message to the target topic via the Pub/Sub gRPC API
- Returns delivery confirmation including the message ID assigned by Pub/Sub
Configuration
| Field | What you choose | Details |
|---|---|---|
| Connection | Google Pub/Sub connection profile | Select a pre-configured connection from your connection library |
| Function | Publish function | Choose a Pub/Sub Publish function that defines the topic, payload, ordering key, and attributes |
| Function Parameters | Message values | Configure dynamic values for topic, payload, ordering key, and attributes using expressions or constants |
For detailed function configuration options including ordering key semantics and attribute formatting, see the Google Pub/Sub Publish Function documentation.
If you want to automatically start a pipeline when Pub/Sub messages arrive (rather than publish within an already-running pipeline), use the Google Pub/Sub Trigger Node instead.