Google Pub/Sub
Google CloudOAuth 2.0Connection test available
Google Cloud Pub/Sub — publish messages (Google OAuth2).
OCNORA ships 34 typed Google Pub/Sub operations. Each node has a schema-driven form, input and output tables beside its settings, and is pre-flighted by Workflow Health before your first real run.
Before you connect Google Pub/Sub
- Authentication
- OAuth 2.0
- Credential
- {"client_id", "client_secret", "refresh_token"}
- Connection test
- Available: the stored credential can be checked against the provider when you add it. This is not a record that a test was run or passed.
What you can do with Google Pub/Sub
Operations, grouped by what they do to your data.
Create and send 5
Read and search 13
Delete and cancel 5
Other operations 8
A sample Google Pub/Sub workflow
- 1A core triggerStart the run from a chat, form, manual, schedule, webhook, workflow trigger — no Google Pub/Sub trigger is needed.
- 2Get Schemapubsub.get_schemaGets a schema.
- 3Acknowledgepubsub.acknowledgeAcknowledge Pub/Sub messages by ack id (e.g. after processing a pull).
An outline built from this provider’s node contracts, not a recorded run. Each step’s output fields are available to the next in the field picker.
Every node below has a reference page: what it does, the connection it needs, its config fields with types, constraints and examples, and the shapes it emits.
Operations 34
- AcknowledgeAcknowledge Pub/Sub messages by ack id (e.g. after processing a pull).pubsub.acknowledge
- Commit SchemaCommits a new schema revision to an existing schema.pubsub.commit_schema
- Create SchemaCreates a schema.pubsub.create_schema
- Create SnapshotCreates a snapshot from the requested subscription.pubsub.create_snapshot
- Create SubscriptionCreate a Pub/Sub subscription (pull, or push to an HTTPS endpoint).pubsub.create_subscription
- Create TopicCreate a Pub/Sub topic in a GCP project.pubsub.create_topic
- Delete Revision SchemaDeletes a specific schema revision.pubsub.delete_revision_schema
- Delete SchemaDeletes a schema.pubsub.delete_schema
- Delete SnapshotRemoves an existing snapshot.pubsub.delete_snapshot
- Delete SubscriptionDeletes an existing subscription.pubsub.delete_subscription
- Delete TopicDelete a Pub/Sub topic (its subscriptions are detached).pubsub.delete_topic
- Detach SubscriptionDetaches a subscription from this topic.pubsub.detach_subscription
- Get SchemaGets a schema.pubsub.get_schema
- Get SnapshotGets the configuration details of a snapshot.pubsub.get_snapshot
- Get SubscriptionGets the configuration details of a subscription.pubsub.get_subscription
- Get TopicGets the configuration of a topic.pubsub.get_topic
- List Revisions SchemaLists all schema revisions for the named schema.pubsub.list_revisions_schema
- List SchemasLists schemas in a project.pubsub.list_schemas
- List SnapshotsLists the existing snapshots.pubsub.list_snapshots
- List Snapshots TopicsLists the names of the snapshots on this topic.pubsub.list_snapshots_topics
- List SubscriptionsList the Pub/Sub subscriptions in a GCP project.pubsub.list_subscriptions
- List Subscriptions TopicsLists the names of the attached subscriptions on this topic.pubsub.list_subscriptions_topics
- List TopicsList Pub/Sub topics in a GCP project.pubsub.list_topics
- Modify Ack Deadline SubscriptionModifies the ack deadline for a specific message.pubsub.modify_ack_deadline_subscription
- Modify Push Config SubscriptionModifies the `PushConfig` for a specified subscription.pubsub.modify_push_config_subscription
- PublishPublish a message to a Google Cloud Pub/Sub topic.pubsub.publish
- PullPull messages from a Pub/Sub subscription and optionally acknowledge them.pubsub.pull
- Rollback SchemaCreates a new schema revision that is a copy of the provided revision_id.pubsub.rollback_schema
- Seek SubscriptionSeeks an existing subscription to a point in time or to a given snapshot, whichever is provided in the request.pubsub.seek_subscription
- Update SnapshotUpdates an existing snapshot by updating the fields specified in the update mask.pubsub.update_snapshot
- Update SubscriptionUpdates an existing subscription by updating the fields specified in the update mask.pubsub.update_subscription
- Update TopicUpdates an existing topic by updating the fields specified in the update mask.pubsub.update_topic
- Validate Message SchemaValidates a message against a schema.pubsub.validate_message_schema
- Validate SchemaValidates a schema.pubsub.validate_schema
Google Pub/Sub questions
- How does OCNORA authenticate with Google Pub/Sub?
- With a stored OAuth 2.0 credential, shaped {"client_id", "client_secret", "refresh_token"}. A connection test can check it when you add it.
- What can I automate with Google Pub/Sub?
- 34 typed operations, each with a reference page listing its config fields and the shapes it emits.
- What if the Google Pub/Sub operation I need is not listed?
- Where Google Pub/Sub has an HTTP API, call it from the HTTP node with the same credential, or describe the step to the AI builder, which asks our team for a typed node when one is missing.
- Are there templates that use Google Pub/Sub?
- Not yet. Start from a blank workflow, or describe the workflow to Build with AI.
- How are Google Pub/Sub calls controlled?
- Every call and every run step is audited, runs count against the execution budget, and Workflow Health pre-flights the workflow when you save it.
See your first Google Pub/Sub workflow run.
Book a technical demo. We add the connection, pick a template or describe the workflow to Build with AI, and Workflow Health checks it before it runs.