Your company runs several streaming Dataflow jobs in separate Google Cloud projects, each triggered by Cloud Composer. SREs want one place to observe end-to-end pipeline lag, receive a PagerDuty alert if lag exceeds five minutes, and inspect individual worker logs without receiving broad project-level permissions. Which architecture best satisfies these requirements while minimizing operational overhead?
Publish Dataflow metrics to Pub/Sub, stream them into BigQuery, use Cloud Scheduler queries to compute lag, trigger Cloud Functions to send PagerDuty alerts, and store worker logs in a BigQuery dataset shared with SREs.
Enable Cloud Trace in every project, export latency traces to a shared Trace project, create alerts on trace duration, and grant SREs Trace Viewer to inspect worker traces.
Create a central operations project, add all pipeline projects to its Cloud Monitoring metrics scope, define an alert on the Dataflow job system_lag metric (>300 s) with a PagerDuty notification channel, and configure aggregated Log Router sinks that export Dataflow worker logs to a log bucket in the operations project where SREs have Logs Viewer access.
Deploy Prometheus on GKE to scrape OpenCensus metrics from Dataflow workers, configure Alertmanager for paging, and set up an Elasticsearch-Kibana stack for logs with Kibana viewer access for SREs.
Using a Cloud Monitoring metrics scope in a dedicated operations project aggregates metrics from multiple service projects automatically, letting engineers build a single dashboard. Dataflow already publishes the job metric system_lag, so an alerting policy that fires when the value is more than 300 seconds can notify PagerDuty. Aggregated Log Router sinks from each project can route Dataflow worker logs into a centralized log bucket where responders are granted the Logs Viewer role, giving them drill-down visibility without exposing wider project access. The other approaches either rely on services that do not natively collect Dataflow lag (Cloud Trace), add unnecessary components and maintenance (custom Pub/Sub → BigQuery or self-hosted Prometheus/Elasticsearch), or still require broader IAM grants.
Ask Bash
Bash is our AI bot, trained to help you pass your exam. AI Generated Content may display inaccurate information, always double-check anything important.
What is a Cloud Monitoring metrics scope?
Open an interactive chat with Bash
What is the system_lag metric in Dataflow?
Open an interactive chat with Bash
What are aggregated Log Router sinks?
Open an interactive chat with Bash
What is a Cloud Monitoring metrics scope in Google Cloud?
Open an interactive chat with Bash
How does the Log Router sink work for exporting logs in Google Cloud?
Open an interactive chat with Bash
What is the system_lag metric in Google Cloud Dataflow?
Open an interactive chat with Bash
GCP Professional Data Engineer
Designing data processing systems
Your Score:
Report Issue
Bash, the Crucial Exams Chat Bot
AI Bot
Loading...
Loading...
Loading...
Pass with Confidence.
IT & Cybersecurity Package
You have hit the limits of our free tier, become a Premium Member today for unlimited access.
Military, Healthcare worker, Gov. employee or Teacher? See if you qualify for a Community Discount.
Monthly
$19.99 $11.99
$11.99/mo
Billed monthly, Cancel any time.
$19.99 after promotion ends
3 Month Pass
$44.99 $26.99
$8.99/mo
One time purchase of $26.99, Does not auto-renew.
$44.99 after promotion ends
Save $18!
MOST POPULAR
Annual Pass
$119.99 $71.99
$5.99/mo
One time purchase of $71.99, Does not auto-renew.
$119.99 after promotion ends
Save $48!
BEST DEAL
Lifetime Pass
$189.99 $113.99
One time purchase, Good for life.
Save $76!
What You Get
All IT & Cybersecurity Package plans include the following perks and exams .