BigQuery

Connects to Google BigQuery to access and analyze large datasets for business intelligence and reporting.

Custom Streaming

Create or update a recurring BigQuery connector. Authentication uses Delphi's managed identity — no credentials need to be stored.

What you can ask Delphi

“How can I set up a daily recurring sync of our BigQuery customer churn model results?”
“What was the total ad spend recorded in our BigQuery marketing analytics dataset for the previous month?”
“Can I analyze the performance of our new product launch based on the BigQuery sales transactions table?”
“Show me the top 10 most profitable customers from our BigQuery customer data warehouse for the last year.”

Authentication ▾

Ingestion ▾

Mode: Streaming

Tools exposed (1) ▾

schedule_bigquery

Create or update a recurring BigQuery connector. Authentication uses Delphi's managed identity — no credentials need to be stored.

Inputs ▾

Name	Type	Required	Description
dashboardId	string	no	Target dashboard/initiative ID. Omit to use the current dashboard.
connectorId	string	no	If provided, updates the existing connector instead of creating a new one.
connectorName	string	yes	Human-readable name for this connector, e.g. 'BigQuery — analytics.sessions table'.
project	string	yes	GCP project ID that owns the BigQuery dataset, e.g. 'my-gcp-project'.
dataset	string	yes	BigQuery dataset ID, e.g. 'analytics' or 'production_data'.
table	string	yes	BigQuery table (or view) to query, e.g. 'sessions' or 'daily_summary'.
columns	string[]	no	Columns to SELECT. Omit or pass ['*'] to select all columns.
where	string	no	SQL WHERE clause (without the WHERE keyword), e.g. "_PARTITIONDATE >= DATE_SUB(CURRENT_DATE, INTERVAL 1 DAY)".
pollingInterval	string	yes	How often polls BigQuery, e.g. '30m', '1h', '6h'. Use 'realtime' for the fastest practical rate (1m). Avoid very short intervals to keep BigQuery costs low.
idExpression	string	no	Optional expression for the deduplication key. Provide when the table has a stable unique key, e.g. 'this.session_id.string' or 'this.row_hash.string'.