Source: Google Cloud Pub/Sub

The Pub/Sub source subscribes to a Google Cloud Pub/Sub subscription and delivers messages into a pg_tide inbox.

Configuration

SELECT tide.relay_set_inbox(
    'events-from-pubsub',
    'incoming_events',
    '{
        "source_type": "pubsub",
        "project_id": "${env:GCP_PROJECT_ID}",
        "subscription": "pg-tide-sub",
        "credentials_json": "${file:/etc/gcp/sa.json}",
        "batch_size": 100
    }'::jsonb
);

Configuration Reference

Delivery Guarantees

Messages are acknowledged only after inbox insertion. The inbox deduplicates using the Pub/Sub message ID. Unacknowledged messages are redelivered after the ack deadline expires.

Further Reading

• Sinks: Pub/Sub — Publishing to Pub/Sub