Google Pub/Sub integration

Google Pub/Sub data, in your warehouse.

A built-in ingestr connector: add credentials, pick tables, schedule it.

name: raw.table
type: ingestr
parameters:
  source_connection: google_pub_sub
  source_table: '<table>'
  destination: snowflake
  incremental_strategy: merge

$ bruin run assets/raw/google_pub_sub.asset.yml

  1. extract · Google Pub/Sub dataincremental
  2. load · snowflake raw.datamerged
  3. checks · not_null, unique

Loaded and checked. Downstream models can run.

How it connects

Connected in three steps.

Google Cloud Pub/Sub is a managed messaging service for event-driven systems and real-time data integration.

  1. 01

    Add a Google Pub/Sub connection with its credentials.

  2. 02

    Pick the tables to load and how: replace, append or merge.

  3. 03

    Bruin runs it on your schedule and checks every load.

Connection parameters

credentialsbase64
Optional base64-encoded Google service account JSON credentials.
endpoint
Optional custom endpoint, useful for the Pub/Sub emulator.
ackdeadlineseconds
Optional ack deadline while ingestr buffers records. Defaults to 300.
pulltimeoutseconds
Optional timeout for each pull request. Defaults to 2.

The platform

Part of the Bruin platform.

Data in, ready for everything downstream: the models, the checks, the lineage and the AI layer.

01 · Move

Data Ingestion

02 · Model & govern

SQL & Python
Data Quality
Data Governance

03 · Use

AI Data Analyst
AI Dashboards
Data Apps
Self-Healing Pipelines
Bruin Cloudorchestration · governance · observability

Frequently asked

Questions about Google Pub/Sub.

Does Bruin have a built-in Google Pub/Sub integration?

Yes. Built-in ingestr source.

Where can Google Pub/Sub data go?

Snowflake, BigQuery, Databricks, Redshift, ClickHouse, Postgres, DuckDB, MotherDuck, Microsoft Fabric and more, plus files on S3 and GCS.

How fresh is the data?

As fresh as your schedule. Incremental loads append, merge or replace a time window, every few minutes if you like.

Do we need Bruin Cloud?

No. The Bruin CLI and ingestr run locally, in CI or in your own orchestrator. Bruin Cloud adds scheduling, lineage, alerts and the AI data analyst on top.

Ready to connect Google Pub/Sub?

$100 in credits and 50 AI tasks. No credit card.

A demo walks through your own data.

Sign up to our newsletter

Practical updates on open-source data pipelines, AI analysts, governance, and what we are shipping at Bruin.

The signup form is hosted by Brevo. Allow marketing cookies to load it.