Unlock the power of your data in the cloud! Get hands-on with Google Cloud's core data services like BigQuery and Looker to validate your practical skills in data ingestion, analysis, and management, and earn your Associate Data Practitioner certification!
Prepare and test your skills
Prepare and test your skills
Worked example. The correct answer is already marked and every option is explained below, so there is nothing to select here. To answer questions yourself, start the free trial.
Keep the momentum going with these hand-picked practice scenarios
Want more questions like this?
Get a free certification question every week.
Last updated
A data engineering team runs batch Dataflow pipelines to process daily analytics data. They want to implement an automated, event-driven architecture that invokes a containerized application hosted on Cloud Run whenever a Dataflow job changes state (such as completing or failing) to perform post-processing cleanup and logging. The Cloud Run target requires authenticated requests.
How should the team configure the pipeline trigger to satisfy these requirements?
Configure an Eventarc trigger with Cloud Storage as the event provider, set Cloud Run as the target, and grant the Pub/Sub Publisher role to the service account.
Create an Eventarc trigger specifying Dataflow as the event provider, select the Cloud Run service as the destination, and associate a service account granted the Cloud Run Invoker role.
Create an Eventarc trigger with Dataflow as the event provider, set Cloud SQL as the target destination, and assign the Cloud SQL Admin role.
Create a Cloud Scheduler cron job that periodically calls the Dataflow REST API and invokes the Cloud Run service using the Dataflow Admin role.
Configure an Eventarc trigger with Cloud Storage as the event provider, set Cloud Run as the target, and grant the Pub/Sub Publisher role to the service account.
Create an Eventarc trigger specifying Dataflow as the event provider, select the Cloud Run service as the destination, and associate a service account granted the Cloud Run Invoker role.
Eventarc is a fully managed Google Cloud eventing service that captures events from Google Cloud sources, custom applications, or third-party platforms and routes them asynchronously to specified targets. When integrated with Cloud Dataflow, Eventarc captures state changes (such as JOB_STATE_DONE, JOB_STATE_FAILED, or JOB_STATE_RUNNING) as direct event notifications without requiring custom polling scripts or complex manual notification channels.
StudyCerts
StudyCertsroles/run.invoker) role via the --service-account parameter.Using Eventarc to directly bind Dataflow state transitions to an authenticated Cloud Run service represents Google Cloud's recommended architectural pattern for event-driven orchestration. It decouples the data processing engine from downstream reporting and maintenance systems, providing a resilient, secure, and low-latency solution.
Create an Eventarc trigger with Dataflow as the event provider, set Cloud SQL as the target destination, and assign the Cloud SQL Admin role.
Create a Cloud Scheduler cron job that periodically calls the Dataflow REST API and invokes the Cloud Run service using the Dataflow Admin role.