Question 141

You orchestrate ETL pipelines by using Cloud Composer One of the tasks in the Apache Airflow directed acyclic graph (DAG) relies on a third-party service. You want to be notified when the task does not succeed. What should you do?
  • Question 142

    An online brokerage company requires a high volume trade processing architecture. You need to create a secure queuing system that triggers jobs. The jobs will run in Google Cloud and cat thecompany's Python API to execute trades. You need to efficiently implement a solution. What should you do?
  • Question 143

    You are implementing several batch jobs that must be executed on a schedule. These jobs have many interdependent steps that must be executed in a specific order. Portions of the jobs involve executing shell scripts, running Hadoop jobs, and running queries in BigQuery. The jobs are expected to run for many minutes up to several hours. If the steps fail, they must be retried a fixed number of times. Which service should you use to manage the execution of these jobs?
  • Question 144

    Which of the following is not possible using primitive roles?
  • Question 145

    Your company is selecting a system to centralize data ingestion and delivery. You are considering messaging and data integration systems to address the requirements. The key requirements are:
    * The ability to seek to a particular offset in a topic, possibly back to the start of all data ever captured
    * Support for publish/subscribe semantics on hundreds of topics
    * Retain per-key ordering
    Which system should you choose?