For a pipeline that reads JSON from Pub/Sub, transforms it, and writes to BigQuery with minimal cost and automatic handling of variable input volume, which service and scaling approach should you choose?
Choose an answer
Tap an option to check your answer.
Correct answer: Use Cloud Dataflow for transformations; monitor job backlog with Stackdriver and use the default autoscaling for worker instances..
Why this is the answer
The correct choice leverages Cloud Dataflow's fully managed, serverless architecture, which inherently provides cost-effectiveness and automatic scaling to handle variable input volumes without manual intervention. Monitoring the job backlog in Stackdriver (now Cloud Monitoring) is crucial for understanding pipeline health and ensuring Dataflow's autoscaling is effectively managing the workload. Cloud Dataproc, while powerful, is a managed Hadoop/Spark service that requires more manual cluster management and scaling, leading to higher operational overhead and potentially higher costs compared to Dataflow for streaming ETL. Manually resizing worker nodes or running diagnostics to adjust resources contradicts the requirement for automatic handling of variable input. Configuring non-default Compute Engine machine types in Dataflow can be useful for specific performance tuning but doesn't address the core requirement of automatic scaling for variable input volume as effectively as Dataflow's default autoscaling. Monitoring total execution time is a good practice but doesn't directly manage the scaling for variable input.
Pass your exam — without the endless answer hunt
Get every verified question and explanation for this exam in one place, and save hours of prep. 1,000+ certifications · 20+ languages · free to start.
Pass your exam faster → No card needed