Connectors

Messaging & Event Streaming

Google Pub/Sub

Cloud messaging: publish messages to topics and consume from subscriptions
Google Pub/Sub API reference
Signs in with
Connection details
Runs on
Cloud or On-Prem Worker
Operations
46
Ready-made triggers
0

Connect Google Pub/Sub

  1. In Neblex open Connect › Connections and click New Connection.
  2. Search for Google Pub/Sub and give the connection a clear name.
  3. Fill in the fields. Secret values are encrypted and never shown again.
  4. Click Test, then Create Connection.
If the system is only reachable inside your network, choose an On-Prem Worker under Test from and run the flow on that Worker. See On-Prem Workers.
FieldWhat to enter
Service account key (JSON)RequiredSecretPaste the full GCP service-account key JSON (project_id, client_email, private_key).

Use it in a flow

  1. Open a flow, open the node library and search for Google Pub/Sub.
  2. Drag it onto the canvas and choose an Operation and your connection.
  3. Map the operation's fields from earlier steps, or click Map with Matt.
  4. Use Test this step to see what it returns, then save.

To start a flow from Google Pub/Sub without a ready-made trigger: a Live stream trigger with Google Pub/Sub as the stream source starts a run for each message as it arrives (see Streaming triggers).

Operations

46 operations in 9 groups. Each one is a step you can add to a flow.

Messages1
Publish a messagepublishPublish a message to a topic (data + attributes + optional ordering key).
Schema access3
Get schema IAM policyget_schema_iam_policyGet the IAM policy attached to a Pub/Sub schema.
Set schema IAM policyset_schema_iam_policyReplace the IAM policy attached to a Pub/Sub schema.
Test schema IAM permissionstest_schema_iam_permissionsReturn the requested permissions granted on a Pub/Sub schema.
Schemas10
Commit a schema revisioncommit_schemaCommit a new revision to an existing schema.
Create a schemacreate_schemaCreate an AVRO or PROTOCOL BUFFER schema.
Delete a schemadelete_schemaDelete a Pub/Sub schema and all revisions.
Delete a schema revisiondelete_schema_revisionDelete one immutable schema revision.
Get a schemaget_schemaGet a schema in BASIC or FULL view.
List schema revisionslist_schema_revisionsList every revision of a schema with explicit pagination and view.
List schemaslist_schemasList project schemas with explicit pagination and view.
Roll back a schemarollback_schemaCommit a new schema revision copied from a selected prior revision.
Validate a messagevalidate_schema_messageValidate exact text, JSON, or base64 bytes against a stored or ad-hoc schema.
Validate a schemavalidate_schemaValidate an AVRO or PROTOCOL BUFFER definition without creating it.
Snapshot access3
Get snapshot IAM policyget_snapshot_iam_policyGet the IAM policy attached to a Pub/Sub snapshot.
Set snapshot IAM policyset_snapshot_iam_policyReplace the IAM policy attached to a Pub/Sub snapshot.
Test snapshot IAM permissionstest_snapshot_iam_permissionsReturn the requested permissions granted on a Pub/Sub snapshot.
Snapshots5
Create a snapshotcreate_snapshotCapture a subscription's acknowledgement state for later seek operations.
Delete a snapshotdelete_snapshotDelete a Pub/Sub snapshot.
Get a snapshotget_snapshotGet a Pub/Sub snapshot and its expiry metadata.
List snapshotslist_snapshotsList project snapshots with explicit pagination.
Update a snapshotpatch_snapshotUpdate mutable snapshot fields through an explicit or derived field mask.
Subscription access3
Get subscription IAM policyget_subscription_iam_policyGet the IAM policy attached to a Pub/Sub subscription.
Set subscription IAM policyset_subscription_iam_policyReplace the IAM policy attached to a Pub/Sub subscription.
Test subscription IAM permissionstest_subscription_iam_permissionsReturn the requested permissions granted on a Pub/Sub subscription.
Subscriptions11
Acknowledge messagesackAcknowledge received messages by their ack ids.
Create a subscriptioncreate_subscriptionCreate a pull (or push) subscription on a topic.
Delete a subscriptiondelete_subscriptionDelete a subscription.
Detach a subscriptiondetach_subscriptionPermanently detach a subscription from its topic and discard its backlog.
Get a subscriptionget_subscriptionFetch a subscription's metadata.
List subscriptionslist_subscriptionsList the project's subscriptions.
Modify ack deadlinemodify_ack_deadlineExtend or shorten the ack deadline for in-flight messages (nack with 0).
Modify push configurationmodify_push_configReplace the push delivery configuration for a subscription.
Pull messagespullSynchronously pull messages from a subscription (returns messages + ack ids).
SeekseekSeek a subscription to a timestamp (replay/discard) or a snapshot.
Update a subscriptionupdate_subscriptionUpdate mutable subscription fields (e.g. push config, ack deadline) via an update mask.
Topic access3
Get topic IAM policyget_topic_iam_policyGet the IAM policy attached to a Pub/Sub topic.
Set topic IAM policyset_topic_iam_policyReplace the IAM policy attached to a Pub/Sub topic.
Test topic IAM permissionstest_topic_iam_permissionsReturn the requested permissions granted on a Pub/Sub topic.
Topics7
Create a topiccreate_topicCreate a Pub/Sub topic.
Delete a topicdelete_topicDelete a Pub/Sub topic.
Get a topicget_topicFetch a topic's metadata.
List a topic's snapshotslist_topic_snapshotsList snapshot names retaining messages from a topic.
List a topic's subscriptionslist_topic_subscriptionsList subscriptions attached to a topic.
List topicslist_topicsList the project's topics.
Update a topicpatch_topicUpdate mutable topic fields through an explicit or derived field mask.