BigQuery — Stream each run into a BigQuery table via the insertAll API — Google's data warehouse.

What it does

[BigQuery](https://cloud.google.com/bigquery) is Google's petabyte-scale serverless data warehouse. This sink streams one row per peepshow run into a BigQuery table via the [`tabledata.insertAll`](https://cloud.google.com/bigquery/docs/reference/rest/v2/tabledata/insertAll) REST endpoint. Auth is an OAuth2 access token (Bearer header) — typically generated with `gcloud auth print-access-token` (user creds) or `gcloud auth print-access-token --impersonate-service-account=...` (service account). The destination table must already exist; the doc captures the expected schema (`run_id STRING · title STRING · frames INT64 · duration FLOAT64 · transcript STRING · thumbnail_url STRING · strategy STRING · tags STRING · created_at TIMESTAMP`) so you can paste it as a `CREATE TABLE`. Token refresh is the caller's responsibility — the sink fails fast on 401 so a CI job retries cleanly with a fresh token.

When to reach for it

• Pipe peepshow runs into the same BigQuery dataset your product analytics lives in
• Build a Looker Studio / Data Studio dashboard over peepshow run history
• Hand a service-account access token to a CI job that records every QA video into a shared warehouse

Install

npm i -g peepshow

Use it

BIGQUERY_PROJECT="my-project" \
BIGQUERY_DATASET="peepshow" \
BIGQUERY_ACCESS_TOKEN="$(gcloud auth print-access-token)" \
peepshow ./demo.mp4 --sink bigquery

Make it automatic

Register the sink once — every run fires it afterward. Scope by --when so it only runs for matching videos.

peepshow sinks add bigquery
peepshow sinks add bigquery --when extension=mp4,mov
peepshow sinks add bigquery --when path=/Volumes/Work/

Configuration

• BIGQUERY_PROJECT GCP project id that owns the BigQuery dataset. required
• BIGQUERY_DATASET BigQuery dataset id (case-sensitive). required
• BIGQUERY_TABLE Table name within the dataset. Default `peepshow_runs`. Must exist with a compatible schema (see docs).
• BIGQUERY_ACCESS_TOKEN OAuth2 access token (Bearer). Generate with `gcloud auth print-access-token` or equivalent. Token refresh is the caller's responsibility. required
• PEEPSHOW_FRAME_BASE_URL When set, the first frame URL is written to the `thumbnail_url` field.

# Add to ~/.zshrc, ~/.bashrc, or a project .env the agent can load
export BIGQUERY_PROJECT="..."
export BIGQUERY_DATASET="..."
export BIGQUERY_ACCESS_TOKEN="..."

peepshow sinks add bigquery
peepshow sinks add bigquery --when extension=mp4,mov

Write your own

A sink is any executable that reads the --emit json payload on stdin. Shell, Node, Python, Go — the spec's in docs/PLUGINS.md. Register persistent ones with peepshow sinks add-cmd 'your-command'.