Skip to main content
Version: v4.22

google-cloud-pubsub

Loads bytes from a Google Cloud Subscription. Publishes bytes to a Google Cloud Topic.

Synopsis​

Loader:

google-cloud-pubsub <project-id> <subscription-id> [--timeout=<duration>]

Saver:

google-cloud-pubsub <project-id> <topic-id>

Description​

The google-cloud-pubsub loader subscribes to a Google Cloud PubSub subscription, the google-cloud-pubsub saver publishes to a Google Cloud PubSub topic.

The connector tries to retrieve the appropriate credentials using Google's Application Default Credentials.

<project-id> (Loader, Saver)​

The project to connect to. Be aware that this is the ID, and not the display name.

<subscription-id> (Loader)​

The subscription-id to subscribe to.

--timeout=<duration> (Loader)​

How long to wait for messages before ending the connection. A duration of zero means the subscription will run forever.

The default value is 0s.

<topic-id> (Saver)​

The topic to publish to.

Examples​

Subscribe to my-subscription in the project amazing-project-123456 and parse the messages as JSON:

load google-cloud-pubsub "amazing-project-123456" "my-subscription"
| parse json

Publish suricata.alert events as JSON the alerts-topic in the

export
| where #schema = 'suricata.alert'
| write json
| save google-cloud-pubsub "amazing-project-123456" "alerts-topic"