Question 1

A manufacturer of delivery drones is implementing a new data analysis pipeline to detect part failures before they occur. The drones have multiple sensors that send performance and environment data to an analytics pipeline. Currently, data is sent to a REST API endpoint. The REST API endpoint that receives data cannot always keep up with the pace data is arriving. When that happens, data is lost. Machine learning engineers have asked you to change the ingestion process to reduce this data loss. What would you do?

Options :

A : Write data to a Cloud Pub/Sub topic instead of a REST API endpoint and have the ingestion application read from the topic.

B : Write data to a Cloud Storage bucket instead of a REST API endpoint and have the ingestion application read from the bucket.

C : Write data to a Cloud SQL Postgres database endpoint and have the ingestion application query the database.

D : Create a Hadoop cluster in Compute Engine using managed instance groups and write data to an Hbase database and have the application query the database.

Answer: A

Question 2

You are designing a Dataflow pipeline for a batch processing job. You want to mitigate multiple zonal failuresat job submission time. What should you do?

Options :

A : Specify a worker region by using the —region flag.

B : Set the pipeline staging location as a regional Cloud Storage bucket.

C : Submit duplicate pipelines in two different zones by using the —zone flag.

D : Create an Eventarc trigger to resubmit the job in case of zonal failure when submitting the job.

Answer: A

Question 3

You want to use a BigQuery table as a data sink. In which writing mode(s) can you use BigQuery as a sink?

Options :

A : Both batch and streaming

B : BigQuery cannot be used as a sink

C : Only batch

D : Only streaming

Answer: A

Question 4

You operate a database that stores stock trades and an application that retrieves average stock price for a given company over an adjustable window of time. The data is stored in Cloud Bigtable where the datetime of the stock trade is the beginning of the row key. Your application has thousands of concurrent users, and you notice that performance is starting to degrade as more stocks are added. What should you do to improve the performance of your application?

Options :

A : Change the row key syntax in your Cloud Bigtable table to begin with the stock symbol.

B : Change the row key syntax in your Cloud Bigtable table to begin with a random number per second.

C : Change the data pipeline to use BigQuery for storing stock trades, and update your application.

D : Use Cloud Dataflow to write summary of each day’s stock trades to an Avro file on Cloud Storage. Update your application to read from Cloud Storage and Cloud Bigtable to compute the responses.

Answer: A

Question 5

Which Java SDK class can you use to run your Dataflow programs locally?

Options :

A : LocalRunner

B : DirectPipelineRunner

C : MachineRunner

D : LocalPipelineRunner

Answer: B

Free Professional-Data-Engineer Mock Exam – Practice Online Confidently

Buying Options: