Google BigQuery Integrations
Connect Google BigQuery with the most popular apps, so you can automate your work and have more time for what matters most — no code required.
Start freeGoogle BigQuery Triggers
New Row
Triggers when a new row is added to a BigQuery table. Polls every 5 minutes by comparing the latest value in a sort column against the previous check.
Updated Row
Triggers when an existing row is updated in a BigQuery table. Requires an `updated_at` TIMESTAMP column that is set whenever a row changes.
Query Job Completed (With Row Data)
Triggers when a BigQuery query job finishes successfully. Each flow run receives the job metadata and the result rows from that query.
New Job Completed
Triggers when any BigQuery job (query, load, copy, or extract) finishes. Returns the job metadata including status, type, and timing.
Google BigQuery Actions
Run a Query
Execute a SQL query on BigQuery and return the results as flat rows
Create Row
Creates a single new row in a BigQuery table. Column fields are loaded from the table schema.
Create Rows
Creates new rows of data in a BigQuery table (accepts an array of row objects). Rows are available to query within seconds.
Delete Rows
Deletes one or more rows from a BigQuery table using a SQL WHERE condition.
Update Row(s)
Updates one or more existing rows in a BigQuery table using SQL SET and WHERE expressions.
Find One Row
Find a single row by specifying a WHERE clause and an optional ORDER BY. Returns the first matching row, or empty if none found.
Find or Create Record
Searches for a row matching a WHERE clause. If found, returns it. If not found, inserts the provided row data and returns that.
Get Rows for Job Completed
Retrieves the result rows from a completed BigQuery query job by Job ID. Use this after a "Query Job Completed" trigger to fetch the full result set.
Import Data
Imports a batch of rows into a BigQuery table. Accepts a JSON array or newline-delimited JSON (NDJSON). Large datasets are automatically split into chunks.
Custom API Call
Make a custom API call to a specific endpoint