GCP-ADP Practice Test 3 — 30 Questions

Question 1

You are processing streaming data in Pub/Sub and need to archive every message into GCS without writing custom code. What should you use?

Accepted Answer

Pub/Sub Cloud Storage subscription. Pub/Sub's native Cloud Storage subscription allows for direct streaming of messages to files in GCS.

Answer

Dataflow

Answer

BigQuery Data Transfer Service

Answer

Cloud Functions

Question 2

Which tool is used to monitor the performance of your Dataflow pipelines?

Accepted Answer

Cloud Monitoring. Cloud Monitoring provides metrics like system lag and CPU utilization for Dataflow.

Answer

Cloud Logging

Answer

BigQuery Console

Answer

Dataprep

Question 3

Which THREE of the following are necessary for a production-ready Dataflow pipeline?

Accepted Answer

Error handling. Monitoring, logging, and error handling are essential.

Answer

Desktop-based processing

Answer

Manual refreshes

Question 4

You need to pass a JSON object into a Workflows execution. How should you format the argument in the 'gcloud workflows executions' command?

Accepted Answer

Use the --data flag with a JSON string.. The '--data' flag accepts a JSON string, which is the standard format for passing parameters to workflows.

Answer

Pipe the JSON into the stdin of the command.

Answer

Use the --env-vars flag.

Answer

Upload the JSON to a GCS bucket and point to it.

Question 5

Which TWO of the following are common reasons a Workflows execution might stay in a 'PENDING' or 'FAILED' state?

Accepted Answer

Invalid YAML syntax. Common issues include invalid IAM permissions or malformed YAML syntax in the workflow definition.

Answer

Airflow scheduler failure

Answer

Database locks

Answer

Worker node exhaustion

Question 6

You are cleaning data using Dataprep. You want to save the final dataset in BigQuery. What do you do?

Accepted Answer

Use the Export feature. In Dataprep, you configure a publishing action to write the results to a BigQuery table.

Answer

Copy the file from GCS

Answer

Use a SQL query

Answer

Wait for Dataflow to finish

Question 7

You need to verify the integrity of a large file uploaded to GCS. What is the standard way to do this?

Accepted Answer

Check MD5 hash. Comparing the MD5 hash provided by GCS against the local file's hash ensures integrity.

Answer

Use Cloud Logging

Answer

Check file size

Answer

Use Dataflow

Question 8

When using Cloud Scheduler to trigger a Workflows execution, what is the best practice for authenticating the scheduler to the Workflows API?

Accepted Answer

Use an OIDC token with a service account.. Using an OIDC token with a service account that has the 'Workflows Invoker' role is the secure, recommended method.

Answer

Use an API Key generated in the console.

Answer

Hardcode credentials in the scheduler job.

Answer

Use 'Public' access for the workflow.

Question 9

Which THREE of the following Cloud Composer 2 features provide improved performance over Composer 1?

Accepted Answer

Unified environment management. Composer 2 offers auto-scaling, custom resource allocation, and environment-level configuration management.

Answer

Requires manual GKE cluster management

Answer

Fixed pricing model

Question 10

You need to store sensitive data in GCS. Which feature ensures data is encrypted at rest?

Accepted Answer

Default Encryption. All data in GCS is encrypted at rest by default using Google-managed keys.

Answer

Identity and Access Management

Answer

Cloud DLP

Answer

Customer-Managed Encryption Keys (CMEK)

Question 11

You need to provide temporary access to a GCS file for a third party. What should you use?

Accepted Answer

Signed URL. Signed URLs provide time-limited access to GCS objects without needing an account.

Answer

Public access

Answer

Bucket Policy

Answer

IAM Role

Question 12

You need to ingest log data into BigQuery from GCS files that arrive sporadically. Which service is best to trigger this?

Accepted Answer

Cloud Functions. Cloud Functions, triggered by GCS object creation events, can automatically load files into BigQuery.

Answer

Cloud Scheduler

Answer

BigQuery Data Transfer Service

Answer

Dataflow

Question 13

You are using BigQuery and need to load data from an external file that is not in GCS. Which method is recommended?

Accepted Answer

Upload to GCS then BigQuery. BigQuery can ingest data from local files via the CLI, or by first uploading them to GCS.

Answer

Use Cloud Functions

Answer

Stream directly from the local machine

Answer

Use an external API

Question 14

Which Cloud Composer metric should you monitor to identify if your Airflow scheduler is struggling to parse your DAGs in a timely manner?

Accepted Answer

dag_processing_total_parse_time. The 'dag_processing_total_parse_time' metric specifically tracks the time taken to process and parse DAG files.

Answer

airflow_task_execution_time

Answer

dag_run_success_count

Answer

scheduler_heartbeat

Question 15

Which TWO are methods to secure GCS data?

Accepted Answer

IAM roles. IAM roles and Cloud KMS encryption are standard security methods.

Answer

Renaming files

Answer

Printing files

Answer

Public internet access

Question 16

What is the primary function of the Airflow 'Executor' in Cloud Composer?

Accepted Answer

Deciding how to distribute tasks to workers.. The executor is responsible for managing the execution of tasks, determining how to distribute work to the workers.

Answer

Serving the Airflow UI web pages.

Answer

Storing the DAG file metadata.

Answer

Automatically scaling the GKE cluster.

Question 17

You need to delete all files in a GCS bucket older than 90 days. What is the most efficient approach?

Accepted Answer

Cloud Lifecycle Management. GCS Lifecycle policies can automatically delete or move objects based on age.

Answer

Manual deletion in the console

Answer

Use Dataflow to filter files

Answer

Write a cron job with gsutil

Question 18

Which TWO of the following are key benefits of using Dataflow?

Accepted Answer

Fully managed. Dataflow is fully managed and supports both batch and streaming.

Answer

Hardware management

Answer

Automatic data entry

Answer

Low-latency SQL queries

Question 19

When configuring a Workflows execution, you want to ensure the workflow can be triggered by an HTTP POST request. Which feature allows this?

Accepted Answer

Executing the workflow via the REST API.. Workflows can be triggered via HTTP POST requests to the workflow execution API endpoint.

Answer

Configuring a Cloud Scheduler job with an HTTP target.

Answer

Enabling the 'HTTP Gateway' on the workflow itself.

Answer

Creating a Service Account with 'Public Access'.

Question 20

In Cloud Composer, what is the default behavior if a DAG execution takes longer than the 'dagrun_timeout' setting?

Accepted Answer

The DAG run is marked as failed.. If a DAG run exceeds the timeout, Airflow marks the DAG run as 'failed'.

Answer

The DAG enters a 'running' state indefinitely.

Answer

The DAG run is paused.

Answer

The scheduler automatically restarts the DAG.