Google BigQuery integration

Google BigQuery data warehouse automation

39 operationsDatabases & Storage

BigQuery is Google Cloud's serverless data warehouse for running SQL over very large datasets. The NoClick BigQuery node talks to the BigQuery REST API, so a workflow can submit queries as jobs, pull the results, create and delete datasets and tables, and manage routines and models. It also reads job status, dataset and table metadata, the project service account, and IAM and row access policies, so warehouse work fits alongside the rest of your stack. Drop it on the canvas and turn scheduled reports, data loads, and ad hoc queries into steps that run on their own.

What you can automate with Google BigQuery

Google BigQuery operations

Triggers1

Queries2

Jobs5

Datasets7

Tables11

Routines5

Models4

Project2

Row Access Policies2

Templates using Google BigQuery

BigQuery Metrics Digest

Runs the exact SELECTs you hand it at 8am, posts the values to Slack with the day on day move, and names any query that failed with the error BigQuery returned. Every company with a warehouse has a dashboard that was supposed to answer this, and nobody opens it. Hand this agent the five or six SELECTs you actually care about and at 08:00 it runs exactly those, drops the values into Slack with the day on day move, and names any query that broke with the error BigQuery gave it. Because a scan is billed by the byte it runs each query once and never retries, so a bad query costs you one failed run instead of a surprise at the end of the month. ## What people use it for - **One scan a day** - Each query runs once every morning, which makes the BigQuery side of this a number you can work out before you start. No retries, no exploratory queries widening a date range behind your back. - **Catch a pipeline that never landed** - When last night's partition is missing the metric comes back as zero and the digest prints zero next to yesterday's real number. That contrast is usually the fastest warning you get that an upstream job died. - **Stop being the human query endpoint** - Analysts get asked for the same six numbers every morning by the same four people. Once those numbers arrive on their own the DMs stop, and the analyst gets their mornings back. - **Dull enough to trust** - Same queries, same order, same names, every day, and a query that failed is stated rather than hidden behind a blank. A number nobody has to double check is the only kind worth posting. ## Before you fork **What access does it need?** A Google Cloud credential with BigQuery Data Viewer on the datasets your queries read and Job User on the project that will run them, plus one Slack channel. Then you paste in your query list with the name each metric should carry, and describe the digest. If you want a hard ceiling, point it at a project with a custom query quota set. **What will this actually cost?** Thirty odd agent runs a month, one each morning, and on the BigQuery side whatever your queries scan. Six well partitioned queries against summary tables is pennies, and the same six against a year of an unpartitioned events table is not, exactly as it would be if a person ran them. A query that fails to compile is not billed, and since the agent never retries, a broken query costs one attempt rather than a loop. **What happens when one of my queries breaks?** The digest still goes out. The broken query gets its own line under QUERIES THAT DID NOT RUN with the BigQuery error copied word for word, including the location it points at, and the owner you named gets tagged. It will not attempt a fix, guess at a replacement table, or quietly leave the metric out, and since it holds only a query tool and a table listing tool, it cannot write anything back to correct itself either.

72004 nodes

Questions

Yes. The node submits your query as a job with Insert Job and reads the output with Get Query Results, so a workflow can run SQL and hand the rows to the next step. You can also check progress with Get Job or stop a running query with Cancel Job.

You authorize the node with your Google account, and it calls the BigQuery REST API for your Google Cloud project. From there it can reach your datasets, tables, jobs, and routines. It can also return the project's BigQuery service account with Get Service Account when you need it for permissions.

Yes. The On Scheduled Query Results trigger starts a workflow when a scheduled query produces results, so fresh data can flow into Slack, a spreadsheet, or another system without polling. Pair it with Get Query Results to read the exact rows the query returned.

It creates datasets and tables, reads their metadata with Get Dataset and Get Table, lists datasets, and deletes datasets and tables when you need to tear them down. That makes it easy to stand up scratch tables for a pipeline and clean them up when the run finishes.

Yes. It manages routines with Create Routine, Get Routine, and Delete Routine, and it can read a model with Get Model or remove one with Delete Model. For governance, it also inspects a table's IAM policy and row access policy so you can audit who can see what.

Give Google BigQuery to an agent

All integrations

Free to start.