GCP-ADP Practice Test 4 — 25 Questions

Question 1

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 2

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 3

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 4

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 5

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.

Question 6

You need to perform data cleansing on a large dataset in Dataprep. Which execution engine should you choose for scalability?

Accepted Answer

Dataflow. Dataprep uses Dataflow as its execution engine to scale to large datasets.

Answer

Local Desktop

Answer

BigQuery

Answer

Cloud Run

Question 7

You are using Dataprep to prepare data. How can you share your work with a team?

Accepted Answer

Share the Flow. Dataprep allows you to share 'Flows' with other project members.

Answer

Copy the JSON definition

Answer

Share the underlying GCS file

Answer

Export to a CSV

Question 8

Which TWO of the following are valid ways to monitor Dataflow performance?

Accepted Answer

Dataflow Monitoring UI. Monitoring UI and Cloud Logging are the primary tools.

Answer

BigQuery logs

Answer

Cloud DNS logs

Answer

Manual packet sniffing

Question 9

Your team needs to audit all modifications made to DAG files in the GCS bucket used by Cloud Composer. What is the most efficient way to achieve this?

Accepted Answer

Enable Data Access audit logs on the GCS bucket.. Enable Cloud Audit Logs (Data Access logs) on the GCS bucket to track all API calls including object modifications.

Answer

Enable 'Version History' in the Airflow UI.

Answer

Use Cloud Monitoring to alert on 'gcs_object_write' events.

Answer

Write a custom DAG to scan the bucket every minute.

Question 10

Which GCS storage class is most cost-effective for data accessed only once per year?

Accepted Answer

Archive. Archive storage is designed for data that is rarely accessed (once a year or less).

Answer

Standard

Answer

Coldline

Answer

Nearline

Question 11

You have a Workflow that must wait for a specific time duration before proceeding. Which step type is most appropriate?

Accepted Answer

sys.sleep. The 'sys.sleep' function in Workflows allows pausing the execution for a defined duration.

Answer

pause_execution

Answer

wait_for_condition

Answer

delay_step

Question 12

Which THREE of the following are valid Airflow connection types in Cloud Composer?

Accepted Answer

HTTP. Airflow supports connections to many systems, including Google Cloud, HTTP, and SQL databases.

Answer

Kubernetes Pod

Answer

Python

Question 13

You need to transfer files from an Amazon S3 bucket to GCS. What is the most efficient method?

Accepted Answer

Storage Transfer Service. Storage Transfer Service has a built-in connector for S3, making it the most direct method.

Answer

Dataflow

Answer

gsutil rsync

Answer

Write a Python script

Question 14

You are migrating a high-throughput on-premises database to BigQuery. You need to ensure zero downtime. What is your best strategy?

Accepted Answer

Datastream. Using Datastream to capture Change Data Capture (CDC) events allows for continuous, near-real-time synchronization.

Answer

Cloud Pub/Sub

Answer

Dataflow batch jobs

Answer

Batch Export/Import

Question 15

You need to perform a rolling update on a Dataflow job without losing current state. How do you do this?

Accepted Answer

Use the Dataflow Update job command. Using the 'Update' feature with a job ID allows you to update the pipeline code while maintaining state (if possible).

Answer

Create a new job and point to the same source

Answer

Stop the job and start it again

Answer

Use a pipeline template

Question 16

Which TWO of the following strategies help reduce Cloud Composer costs?

Accepted Answer

Delete unused environments. Stopping unused environments and using environment auto-scaling are effective cost-saving measures.

Answer

Keep all historical logs forever

Answer

Use the largest environment size

Answer

Increase scheduler frequency

Question 17

You need to load CSV files from GCS to BigQuery. The schema changes frequently. Which approach handles schema evolution automatically?

Accepted Answer

BigQuery Load job with auto-detect. BigQuery schema auto-detection combined with ingestion into a landing table supports schema evolution if configured properly.

Answer

Dataprep with rigid recipe

Answer

Cloud Functions with manual schema mapping

Answer

Dataflow with fixed schema

Question 18

You are using Dataflow with a custom container. Which command do you use to specify the container image?

Accepted Answer

--sdk_container_image. The --sdk_container_image flag in the Dataflow runner specifies the image.

Answer

--container_path

Answer

--custom_image

Answer

--worker_image

Question 19

You need to ensure that deleted files in GCS can be restored for 30 days. What should you configure?

Accepted Answer

Object Versioning. Object Versioning keeps versions of objects, and Lifecycle policies can delete older ones, but Object Versioning alone is the core feature here.

Answer

Cloud Storage bucket lock

Answer

Bucket Lifecycle policy

Answer

IAM

Question 20

Which THREE features does Dataprep provide?

Accepted Answer

Data profiling. Dataprep provides data profiling, transformation, and sampling.

Answer

Direct database writes

Answer

Machine Learning model training