scenario questions

You have a large table in BigQuery that is updated constantly. You need to perform a query that is consistent. What should you use?

Which TWO of the following are true regarding Dataplex security? (Choose two)

Which TWO of the following are common Dataflow pipeline patterns?

Your team runs a Cloud Composer 2 environment that processes financial data. A critical DAG must run exactly once per day at 02:00 UTC, and the Airflow scheduler must not backfill missed runs from the previous week when the DAG is unpaused. You need to configure the DAG so that only future scheduled runs execute. What should you set in the DAG definition?

You are building a Looker Studio report and need to display a calculated field that shows the profit margin as a percentage. The data source contains fields for revenue and cost. Which expression should you use for the calculated field?

Your team stores daily clickstream data as newline-delimited JSON files in a Cloud Storage bucket. The ingestion pipeline must load each day's files into BigQuery, and the JSON structure occasionally gains new top-level fields between days. You want BigQuery to infer the schema automatically at load time and add any newly observed columns without failing the load. Which load configuration should you use?

You are using Airflow with a Cloud Composer environment. You want to ensure that a specific task runs on a specific day of the week. How do you configure the schedule?

You need to control access to specific columns in a BigQuery table using Dataplex-integrated policy tags. What must you create before you can apply a policy tag to a column?

A fintech firm streams transaction events into a Pub/Sub topic. The analytics team needs near-real-time aggregates in BigQuery and must also retain the raw events for seven years in Cloud Storage for compliance. They want a managed service with minimal code. Which pipeline should you recommend?

A retail company stores point-of-sale events in Pub/Sub and wants them available for SQL analysis in BigQuery with minimal operational overhead and near-real-time latency. The team has no servers to manage and wants the simplest supported path. Which approach should they use?

A retail company ingests point-of-sale events into BigQuery. Analysts frequently filter by store_id and by transaction date, and the table grows by several hundred gigabytes per month. You want to reduce the bytes scanned by these filtered queries with the least effort. What should you do?

A data team stores raw event data in a BigQuery table called `events` with columns `event_time` (TIMESTAMP), `user_id` (STRING), and `event_type` (STRING). The table is partitioned by DATE(event_time). Analysts frequently run queries that filter on `event_type` and also restrict `event_time` to the last 7 days. These queries scan the entire 7-day partition range, causing higher-than-expected costs. The team wants to reduce bytes scanned without changing the table's partitioning scheme. What should they do?

Your organization stores raw event data in a Cloud Storage bucket that receives new files throughout the day. Analysts want to query this data with SQL in BigQuery without loading it into native BigQuery storage first. The data is in Parquet format and partitioned by date in the folder structure. What should you create?

You are designing a data lake in Cloud Storage and need to ensure that data is organized for efficient querying by BigQuery and other analytics services. You plan to use a Hive-style partitioned directory structure. Which two practices should you follow? (Choose two.)

You are building a Dataflow pipeline that reads from Pub/Sub and writes to BigQuery. Some messages contain malformed JSON that causes the pipeline to fail repeatedly. You want the pipeline to continue processing valid messages and send the bad records to a dead-letter location for later analysis. Which Dataflow feature should you use?

Which TWO of the following are true about Workflows' serverless nature?

Your company stores sensitive customer records in a Cloud Storage bucket. A compliance officer requires that every object in the bucket be automatically classified and that any object containing credit card numbers be flagged for review. You want a managed Google Cloud service that samples and inspects the data without writing custom code. What should you use?

You need to track lineage for a BigQuery table populated by a Dataflow pipeline. How does Dataplex help?

You are designing a streaming pipeline in Dataflow. You need to ensure that data is processed in the order it was generated, even if it arrives late. What do you use?

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

You want to enforce that all data in a specific Dataplex Zone must be encrypted with a Customer-Managed Encryption Key (CMEK). How do you enforce this?

A data analyst is using Looker Studio to create a dashboard for a sales team. They want to enable users to interact with the data and explore different dimensions without leaving the dashboard. Which two features should they add to the report? (Choose two.)

You are designing a Dataflow streaming pipeline that reads from Pub/Sub and writes to BigQuery. The pipeline must handle late-arriving data and you want to emit correct results for each 5-minute window even when events arrive up to 10 minutes late. You also want to minimize cost by not keeping windows open indefinitely. Which combination of Dataflow features should you use?

What is the primary function of a Looker Explore?

What is the primary benefit of using partitioned tables in BigQuery?

You maintain a Cloud Composer 2 DAG that processes files as they land in Cloud Storage. Instead of polling, you want the DAG to start processing within seconds of a new object being created, and you want the trigger to be reliable even if the Composer environment is briefly restarting. Which approach should you use?

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

You need to analyze a petabyte-scale dataset in BigQuery. To optimize cost, you must ensure that users only query relevant partitions. How should you enforce this?

How do you restrict access to a specific GCS bucket to only members of a specific team?

You are building a Workflows definition that calls a Cloud Run service and then passes the returned JSON payload to a Cloud Function. The Cloud Run response body is stored in a variable named result. Which syntax correctly passes that value as an argument in the subsequent call step?

You are analyzing a BigQuery table of e-commerce orders and want to identify the top 5 product categories by total revenue for each month in 2024. You need to produce a result set with columns `order_month`, `category`, and `total_revenue`. Which SQL technique should you use?

Which of the following describes the purpose of 'BigQuery ML'?

You notice your Looker dashboard is showing duplicate data. What is the most likely cause?

You need to load a large CSV file from Cloud Storage into BigQuery. The file has a header row and uses comma delimiters, but the data contains commas within quoted fields. Which BigQuery load option should you use to correctly parse the file?

A user needs to see the distribution of values in a column in BigQuery. Which visualization approach is most effective for this?

In Looker, what is the impact of defining a 'primary_key' in a LookML view?

Your Cloud Composer DAG includes a task that runs a long-running data export, and you have observed that the task sometimes exceeds the default Airflow worker pod timeout, causing the task to be killed and retried. You want to increase the allowed execution time for this task without affecting other tasks. What should you do?

Which BigQuery feature allows you to monitor query usage and identify expensive queries?

Your team needs to ingest data from an on-premises Oracle database into BigQuery with minimal latency and without writing code. The database is behind a firewall and cannot be accessed directly from the internet. You want to use a fully managed Google Cloud service. What should you use?

Which service is the primary tool for managing and running Jupyter notebooks in a managed environment within Google Cloud?

An analyst has a BigQuery table of website events partitioned by event_date. A stakeholder asks for a quick chart of daily active users for the last 30 days, and cost must stay minimal. Which query pattern best satisfies this request?

You are designing a data ingestion pipeline that must handle late-arriving data in a streaming source. The data arrives with timestamps that may be up to 10 minutes behind the current time. You need to ensure that all data is processed correctly and that windowed aggregations include late data. Which Dataflow feature should you use?

You are analyzing query performance in BigQuery. You notice that your queries are spilling to disk. What is the most likely cause?

Which role is required to manage Dataplex assets within a Zone?

An analyst has a BigQuery table `events.clicks` with columns `event_ts`, `country`, and `clicks`. They want a Looker Studio time series that shows a rolling 7-day average of clicks per country, updating as new data lands. The analyst wants the rolling calculation to happen in the database rather than in the visualization. What is the most appropriate approach?

You are using Dataflow to process a stream of JSON messages from Pub/Sub. The messages contain a timestamp field, but the event time is sometimes delayed by up to 30 minutes. You need to handle these late-arriving events correctly. What should you configure in your pipeline?

A healthcare analytics team stores patient encounter records in Cloud Storage as CSV files and needs to run SQL over them in BigQuery without loading or duplicating the data. The files must remain the system of record, and the team wants to avoid storage charges for a second copy. Which BigQuery feature should they use?

You are designing a data governance strategy for a BigQuery environment. You need to automatically apply policy tags to columns that contain sensitive data so that only authorized users can query those columns. Which two actions should you take? (Choose two.)

You want to perform data quality checks on a BigQuery table that is updated daily. How should you schedule the Dataplex task?

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

Which THREE of the following are key benefits of using Cloud Composer for data orchestration?

Which of the following is NOT a benefit of using Dataplex?

You are planning to ingest log data into Google Cloud. Which THREE of the following services support streaming ingestion?

Which THREE features does Dataprep provide?

Which TWO of the following tools allow you to interact with Dataplex? (Choose two)

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

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

A Cloud Composer environment is experiencing high latency in the Airflow UI. What is a common cause and mitigation for this?

You are loading a 4 TB compressed CSV file from Cloud Storage into BigQuery using a load job. The file has a header row and uses pipe delimiters. You need the load to complete as fast as possible and minimize cost. What should you do?

When creating a dashboard in Looker Studio, which connector type allows you to connect to an arbitrary SQL query?

A data analyst needs to create a Looker Studio report that shows sales data filtered by region. The report must allow users to select one or more regions from a drop-down menu, and the selection should update all charts on the page. Which control should be added to the report?

You are the data engineer for an online retailer. A Cloud Storage bucket named orders-raw contains daily CSV exports from an on-premises order management system. Each file is named with a date stamp, and new files arrive once per day. You need to load this data into BigQuery with minimal ongoing operational effort, and the load must automatically pick up each new file as it arrives. What should you do?

Which TWO of the following are valid ways to visualize BigQuery data within the Google Cloud ecosystem?

Which THREE of the following are common administrative tasks when managing a Dataplex Lake? (Choose three)

You are building a Looker Studio report connected to a BigQuery table that contains billions of rows. The report includes several charts and filters. Users report that the report is slow to load and that changing a filter takes a long time. Which TWO actions should you take to improve performance? (Choose two.)

Which GCP tool provides a managed way to run Apache Airflow workflows?

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

You have a Cloud Composer 2 DAG that uses a PythonOperator to run a script that connects to a Cloud SQL database. The script needs a password. You want to avoid hardcoding the password in the DAG or in environment variables. What should you do?

Which TWO of the following are best practices for managing Cloud Composer DAG dependencies?

Which THREE are features of Pub/Sub?

Which THREE features does Looker offer to support data governance?

You are building a Dataflow pipeline that reads from Pub/Sub and writes to BigQuery. The pipeline must handle late-arriving data up to 1 hour after the event time and still include it in the correct window. Which Dataflow feature should you configure?

You need to ensure data compliance for PII. Which THREE of the following tools or features should you use in combination with Dataplex? (Choose three)

Which THREE of these are valid ways to monitor or analyze BigQuery performance?

Which THREE items can be added to a Looker Studio report to enhance interactivity?

When setting up a new Dataplex Lake, which TWO of the following configurations are required? (Choose two)

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

You need to anonymize PII (Personally Identifiable Information) before loading data into BigQuery. Which tool is best?

Which THREE of the following are valid methods for troubleshooting failed tasks in Cloud Composer?

A compliance officer requires that a Cloud Storage bucket holding customer records retain every object version for seven years, and that no user, including project owners, be able to delete or overwrite those versions during that period. You need a configuration that enforces this even against accidental or malicious deletion attempts. What should you configure?

Which TWO of the following are recommended practices when designing a Dataflow pipeline for high-throughput streaming ingestion?

You have a Dataplex Lake containing data from two different regions. How does this affect data access?

A team wants to display a BigQuery query result inside a Google Sheets spreadsheet so non-technical staff can view the latest figures. The data must refresh automatically each morning without anyone opening the sheet and clicking a refresh button. What should the team configure?

You are working in a Vertex AI Workbench notebook and want to list the files in your current working directory. What command should you run?

A junior analyst has written a BigQuery SQL statement that joins an orders table to a customers table and then aggregates total spend per customer. Before running it against production data, the analyst wants to confirm the query is syntactically valid and to see estimated bytes processed without incurring charges for scanning the full tables. What should the analyst do?

A BigQuery table has 10 billion rows. You notice a query performing a cross-join is timing out. What should you do?

You have a Data Catalog taxonomy that you want to share across multiple projects. How do you achieve this?

You are orchestrating a pipeline with Workflows that invokes several Cloud Functions. You need to pass the output of one function as an argument to the next. What is the correct syntax?

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

You have a Looker Studio report that uses a BigQuery data source. You need to add a chart that shows the total number of orders per day for the last 30 days. The date field is named `order_date`. Which chart type and dimension setup should you use?

You are using Cloud Composer to orchestrate a data pipeline. A critical task in your DAG is failing intermittently due to a known transient error in an external API. You want to automatically retry the task up to 5 times with a 2-minute delay between retries. Which Airflow feature should you configure to achieve this?

You need to create a visualization in Looker Studio that shows the proportion of total sales by product category. Which chart type is most appropriate?

What is the role of the 'Dataplex Data Steward'?

Which TWO of the following are valid ways to trigger a Cloud Composer DAG?

Your team stores customer feedback in a BigQuery table with a column `feedback_text`. You need to count how many times each of the words 'fast', 'slow', and 'broken' appears across all feedback rows. You want to run this as a single SQL query in BigQuery. Which approach should you use?

Which console menu would you navigate to in order to access Dataplex?

You are designing a Cloud Composer 2 DAG that must process files as they arrive in a Cloud Storage bucket. You want to minimize latency and avoid unnecessary worker resource consumption. Which TWO approaches should you use? (Choose two.)

Your organization requires that all data ingested into Cloud Storage be encrypted at rest using keys managed by you, not Google. Which feature should you implement?

A financial analyst needs a Looker Studio report that displays the same revenue chart but filtered by a different region on each of four pages, without duplicating the underlying BigQuery data source. The report currently uses one chart that reads from a BigQuery view. What should the analyst do to reuse the chart across pages with different region filters?

A retail analytics team stores point-of-sale transactions in a BigQuery table named `sales.transactions` that is partitioned by a DATE column called `transaction_date`. An analyst must produce a report showing only the transactions from the previous calendar month, and the report will be refreshed on the first day of every month. Which query pattern most efficiently retrieves the required data while minimizing bytes processed?

You are using BigQuery and need to query a large dataset that is partitioned by day. Which clause should you always include for efficiency?

You need to load a 5 TB uncompressed CSV file from Cloud Storage into BigQuery. The file is too large to load in a single job. What is the recommended approach?

A media company ingests clickstream events into Pub/Sub and processes them with Dataflow before loading into BigQuery. They need to reduce the number of duplicate records that reach BigQuery while keeping the pipeline streaming and low-latency. Which two approaches should they use? (Choose two.)

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

You are deploying a Cloud Composer 2 environment and need to ensure that the DAG files are automatically synchronized to all workers. Where should you store these files?

Which TWO actions can help reduce the time it takes to build a Jupyter notebook in Vertex AI Workbench?

In BigQuery, what does the 'Data Preview' tab show?

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

In BigQuery, you want to improve query performance for a table that is frequently filtered by a `customer_id` column. What is the recommended strategy?

A Cloud Composer DAG is failing because the Airflow database is locking up during high-concurrency periods. What is the most effective way to address this?

You are troubleshooting a stuck task in Cloud Composer. You want to see the stdout/stderr logs for that specific task attempt. Where can you find them?

You are designing a Cloud Workflows pipeline that calls a series of Cloud Functions. The output of the first function must be passed as an argument to the second function, and the output of the second to the third. You need to define the workflow in YAML. Which Workflows syntax correctly assigns the result of a function call to a variable and then uses that variable in a subsequent call?

You are running a Dataflow job that joins two large datasets. Which join strategy should you avoid to prevent OOM errors?

You have a BigQuery table that is partitioned by day on a DATE column. You need to ensure that data older than 90 days is automatically deleted to reduce storage costs, while keeping the table structure and recent data intact. What should you do?

A Cloud Composer 2 task runs a Python script that performs a long-running data transformation and regularly exceeds the default worker pod timeout, causing tasks to be killed and marked as failed. The transformation cannot be shortened and must complete within a single task. What should you do to allow the task to run to completion?

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

You need to move an asset from one Dataplex Zone to another. What is the correct procedure?

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

You are optimizing a Dataflow job. Which THREE of the following actions can help improve job performance and reduce costs?

Which property in a Workflows YAML definition is required to define the entry point of the workflow?

You need to track who accessed which GCS bucket. Which service provides this audit trail?

Your team runs a nightly Apache Spark job on a Dataproc cluster to cleanse raw event logs stored in Cloud Storage. The job currently reads the raw data, transforms it, and writes Parquet files back to Cloud Storage for downstream BigQuery external tables. The job duration has grown from 20 minutes to over 3 hours as data volume increased, and the cluster is a fixed-size 10-node cluster. You want to reduce runtime without rewriting the Spark code. What should you do?

Your organization stores sensitive customer data in a Cloud Storage bucket. You need to ensure that data is automatically classified and tagged as 'PII' when it is written, and that the tags are available for audit and access control decisions. You want to minimize manual effort and use Google Cloud native tooling. What should you do?

Your team ingests JSON event files into Cloud Storage, and you must load them into BigQuery daily. The files contain a field named `user_info` that holds a nested JSON object with varying keys. You want BigQuery to store this field as a native STRUCT so analysts can query subfields with dot notation. Which schema type should you define for the `user_info` column when creating the table?

What does 'Data Lineage' show you in Dataplex?

A data engineer needs a lightweight, serverless orchestrator on Google Cloud to run a sequence of HTTP calls to internal microservices, retry the calls a few times on failure, and expose the whole sequence as a single REST endpoint. The workflow must not require provisioning any cluster or VM. Which Google Cloud service should be used?

You are designing a Cloud Composer 2 DAG that must run a task only after a daily file has arrived in a Cloud Storage bucket. You want the DAG to avoid failing prematurely and to avoid consuming a worker slot while waiting. Which two approaches should you use? (Choose two.)

Which component of Cloud Composer acts as the primary interface for managing and triggering DAGs manually?

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

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

In a Cloud Composer DAG, you need to trigger a BigQuery job that runs as a service account other than the one assigned to the GKE nodes. How should you implement this?

Your organization uses Workflows to orchestrate multi-step API calls. You need to handle transient failures in a specific HTTP request by retrying it up to 5 times with exponential backoff. Which block should you use?

You are orchestrating a data pipeline in Cloud Composer 2. A task in your DAG downloads a large dataset from Cloud Storage and can take up to 45 minutes to complete, but it occasionally fails and needs to be retried. You want the task to automatically retry up to 3 times with a 5-minute delay between attempts. Which Airflow task parameter should you configure to achieve this?

A data analyst is building a Looker Studio report connected to a BigQuery table. The report needs to display data for the last 30 days, but the underlying table is updated daily at midnight. Which approach ensures the report always shows the most recent 30 days without manual intervention?

You need to grant a data analyst read-only access to a specific BigQuery dataset. The analyst should be able to query tables but must not be able to modify data or view other datasets in the project. Which IAM role should you grant on the dataset?

You are designing a BigQuery table for a fleet of IoT devices that emit one reading per second. The table will hold years of data, and most queries filter by device identifier and a time range. You want to reduce the bytes scanned by these queries and control long-term storage cost. (Choose two.)

You are designing a Looker Studio report for a sales team. The report must allow users to filter data by region and product category, and also drill down from country to city. Which two features should you implement to meet these requirements? (Choose two.)

Which TWO are common causes of Dataflow pipeline failures?

You are designing a data ingestion pipeline that uses Pub/Sub to capture real-time events. You need to ensure that messages are processed exactly once and in order. Which two features should you configure? (Choose two.)

You need to migrate legacy data to a Dataplex Lake. Which THREE of the following should you consider for a successful migration? (Choose three)

You are configuring a Dataplex asset that points to a GCS bucket. You want to ensure that only files in a specific folder are included in the asset. How do you specify this?

You have an automated pipeline that deletes files in a GCS bucket every hour. Dataplex shows the asset as 'Out of sync'. Why?

A data analyst is using BigQuery ML to create a linear regression model to predict customer lifetime value based on historical data. After training the model, they want to evaluate its performance. Which BigQuery ML function should they use to get evaluation metrics such as R-squared and mean absolute error?

You need to set up an alert when a GCS bucket exceeds a certain size. Which tool do you use?

Your team runs a Cloud Composer 2 environment where several DAGs import a shared internal Python library. After a library update, tasks begin failing with ModuleNotFoundError across all workers. You need the library to be installed automatically on every worker and scheduler node, including after autoscaling events. What should you do?

A data analyst must present BigQuery results to executives in a way that lets them explore trends by region and product without writing SQL. The team is standardizing on Google Cloud tools and wants the presentation layer to query BigQuery directly. Which two Google Cloud components should the analyst combine to meet these requirements? (Choose two.)

You need to audit who accessed sensitive data in a Dataplex Lake. Which service should you monitor to see access logs for these data assets?

You are processing streaming data in Dataflow and notice 'stuck' elements causing pipeline latency. Which feature helps debug this?

A data engineer needs to load a 500 GB CSV file from a Cloud Storage bucket into a BigQuery table once per day. The CSV has a header row and uses comma delimiters. The engineer wants the simplest managed approach that requires no code and handles schema autodetection. What should the engineer use?

A data engineer is building a Looker Studio report connected to a BigQuery table. The report must allow viewers to dynamically change the date range and filter data by region without editing the report. The engineer wants to add interactive controls. Which two components should be added to the report to meet these requirements? (Choose two.)

You want to share a BigQuery dataset with a partner who uses a different Google Cloud project. What is the most secure way to grant them access?

You need to perform a time-series analysis in BigQuery. Your data contains timestamps at a millisecond level, but you need to aggregate by hour. What is the most performant way to truncate the timestamp?

You are using Dataflow to read from Pub/Sub. The pipeline is failing due to malformed messages. How can you handle these without crashing?

A retail analytics team stores raw clickstream events in a Cloud Storage bucket. They want to query this data with BigQuery using standard SQL without loading it into BigQuery native storage, and they want to minimize cost by avoiding duplicate storage. Which Google Cloud feature should they use?

You are using Workflows to orchestrate a data pipeline that includes a step calling a Cloud Function. The Cloud Function returns a JSON payload with a field named 'result'. You need to pass this 'result' value to a subsequent step as an argument. How should you reference the output of the Cloud Function step in the Workflows YAML?

You need to load a large CSV file from Cloud Storage into BigQuery. The file contains a header row, and you want to automatically detect the schema. You also need to ensure that if any row has a type mismatch, the load job fails and reports the error. Which load configuration should you use?

A retail analytics team stores transaction data in a BigQuery table named `sales.transactions` with columns `order_id`, `customer_id`, `order_ts`, and `amount`. A Looker Studio report uses this table as its data source. The team wants every report viewer to see only rows where `amount` is greater than 0, without modifying the underlying BigQuery table. Where should they enforce this filter so it applies to the entire report regardless of which chart a viewer interacts with?

A colleague must load a 200 GB uncompressed CSV file from a Cloud Storage bucket into a BigQuery table once, with the lowest possible load cost and no transformation. They want the simplest option that BigQuery handles natively. What should they use?

You are designing a Dataflow pipeline that reads from Cloud Storage and writes to BigQuery. The input files are in Avro format and contain a field with a timestamp that is often null. You need to ensure that records with null timestamps are not dropped but are assigned a default timestamp of the pipeline start time. Which approach should you use?

Which TWO are valid methods to trigger a Dataflow job?

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

You are troubleshooting a Dataflow job that is running slower than expected when writing data to BigQuery. You suspect the issue is related to hot keys. What is the recommended strategy to mitigate this?

You want to dynamically generate tasks in an Airflow DAG based on the number of files in a GCS bucket. What is the standard way to do this?

A data analyst is working in BigQuery and needs to create a visualization that shows the relationship between advertising spend and revenue for each day over the past month. The data is in a table with columns `date`, `ad_spend`, and `revenue`. They want to quickly identify if there is a correlation. Which type of chart should they use in Looker Studio?

Which THREE of the following are common steps in a typical data pipeline orchestration pattern?

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

You need to load a 4 TB uncompressed CSV file from Cloud Storage into BigQuery. The file has 200 columns, and you want the load to complete as quickly as possible while minimizing cost. The data is already clean and does not require transformation. Which approach should you take?

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

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

A healthcare organization needs to analyze sensitive patient data in BigQuery while ensuring that analysts can see aggregated results but cannot view individual patient identifiers. Which Google Cloud feature should they implement?

You are creating a Looker Studio report that must allow users to interactively explore sales data. The report should include controls that let users filter data by product category and date range. Which two controls should you add? (Choose two.)

When designing a Looker dashboard, you need to display a value that is the average of a specific metric across the entire dashboard. What is the best method?

You are configuring a Dataplex Data Quality task. You want to validate that a 'user_id' column has no NULL values. Where do you define this rule?

You are developing a dashboard in Looker. You notice that the 'Explore' menu is missing a specific set of fields. What should you check in the LookML model?

Your team runs a Cloud Composer 2 environment with several DAGs that process data in Cloud Storage. You need to design a DAG that reliably handles transient failures when calling the Cloud Storage API. The DAG should retry failed tasks automatically without manual intervention, but you also want to avoid overwhelming the API during an outage. Which combination of Airflow features should you implement to achieve this?

You are identifying trends in a large dataset using BigQuery. Which SQL function is best suited to identify the top 5 products sold per region?

You manage a BigQuery dataset that contains a table with 500 TB of historical order data. Analysts frequently run queries that filter on the `order_date` column. Query costs are rising because every query scans the entire table. You want to reduce the bytes scanned and cost without changing the table name or existing SQL. What should you do?

A data team is building a BigQuery ML model to predict customer churn directly from a BigQuery table. They want to evaluate the model's quality and understand which input features influenced its predictions. Which two BigQuery ML capabilities should they use to accomplish these goals? (Choose two.)

Your team runs an Apache Airflow environment on Google Cloud Managed Service for Apache Airflow. A daily ingestion DAG must wait for a partner team's separate DAG to finish loading a landing table before it can begin its own transformation. The partner DAG is in the same Airflow environment but runs on an unpredictable schedule. You want the dependency handled natively by Airflow rather than with a fixed sleep or time sensor. What should you configure?

A data analyst has a BigQuery table named `sales` with columns `order_date` (DATE), `product_id` (STRING), and `revenue` (NUMERIC). They need to create a report that shows total revenue per product for the last 30 days, but only for products that generated more than $10,000 in that period. They want the result sorted by revenue descending. Which SQL query should they use?

Which TWO of the following are valid locations for a Dataplex Lake? (Choose two)

What is the benefit of using 'Scheduled Reports' in Looker?

Which THREE of the following are valid GCS storage classes?

A user is running a query on a BigQuery table with nested data (JSON). How do you access a field named 'city' inside a record field named 'address'?

You need to prepare data for analysis in BigQuery. You have a CSV file in Cloud Storage that contains personally identifiable information (PII) such as email addresses and phone numbers. You must obfuscate this PII before loading it into BigQuery. Which two Google Cloud services or features can help you achieve this? (Choose two.)

A marketing manager needs to see daily sales trends in Looker. The underlying data is in BigQuery and is updated every 6 hours. What is the best way to visualize this?

You are designing a data lake in Cloud Storage and need to ensure that analysts can query the data using BigQuery without moving or copying the data. You also need to enforce fine-grained access control at the column level for sensitive fields. Which two actions should you take? (Choose two.)

Which service allows you to view the schema and metadata of a BigQuery table that has been registered in Dataplex?

What is the purpose of a 'Data Zone' in Dataplex?

Your team uses Dataprep by Trifacta to clean data before loading it into BigQuery. You notice that the column header names contain inconsistent casing and special characters. Which Dataprep transformation should you use to standardize these headers globally?

You have a Looker Studio report connected to a BigQuery table that contains millions of rows. The report takes a long time to load and often times out. You need to improve performance without changing the underlying data. What should you do?

A team maintains a Looker dashboard fed by a BigQuery table that receives streaming inserts throughout the day. Users report that totals on the dashboard sometimes disagree with a report generated directly in BigQuery a few minutes later. What is the most likely explanation for the discrepancy?

You are using Vertex AI Workbench and want to ensure your notebook environment persists after the instance is stopped. Where should you save your work?

Your team uses Cloud Composer (Airflow) to run a daily ETL DAG. A task occasionally fails due to transient network errors when calling an external API. You want the task to retry automatically up to 3 times with a 5-minute delay between attempts, and you want the DAG to continue running other tasks even if this task ultimately fails. Which combination of Airflow task parameters should you configure?

You are using Cloud Scheduler to trigger a Cloud Workflows execution every hour. You need to ensure that the scheduler authenticates to the Workflows API securely. Which two of the following are valid methods for authenticating Cloud Scheduler to Workflows? (Choose two.)

You are building a Looker dashboard and need to calculate the year-over-year growth rate. Which feature should you use to perform this without modifying the underlying SQL?

Your Workflows definition calls three Cloud Run services in sequence. The second service occasionally returns HTTP 503 during cold starts, and you want Workflows to retry those specific failures with exponential backoff while treating HTTP 400 responses as permanent failures. How should you configure this?

You have sensitive data in Cloud Storage that needs to be deleted after 30 days to comply with regulatory requirements. What is the most efficient way to manage this?

You need to ingest data from a MySQL database into BigQuery. The database is updated continuously, and you need near-real-time replication with minimal impact on the source database. You also want to avoid writing custom code. What should you use?

Which command-line tool do you primarily use to deploy and manage Workflows?

In Dataflow, what is the impact of using a high number of workers for a small dataset?

You need to run a Workflows execution based on a schedule. Which Google Cloud service is designed to manage this triggering?

Your team is ingesting streaming clickstream events from Pub/Sub into BigQuery. You need to ensure that the pipeline can handle duplicate message deliveries without creating duplicate rows in the destination table. What should you do?

You manage a BigQuery dataset that contains a table with millions of rows. Analysts frequently query only the most recent 30 days of data, but full-table scans are expensive. You need to reduce query costs and improve performance for these time-based queries with minimal changes to the table structure. What should you do?

When creating a Looker visualization, which chart type is best for showing the relationship between two numerical variables?

Which service should you use to search for and discover datasets across your entire Google Cloud organization?

What happens if you delete a Dataplex Lake?

You are creating a Looker report with a 'measure' that calculates the total revenue. You notice it is summing correctly but the format is wrong. Where do you change the format?

A product team uses Looker Studio to visualize metrics from a BigQuery table that is updated by an hourly ETL job. Users report that the dashboard shows data that is several hours stale even though the ETL completes successfully. The data source was configured with a custom query rather than a direct table reference. What is the most likely cause of the staleness?

When reviewing a Looker dashboard, which icon do you click to reload the data?

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?

You are querying a dataset in BigQuery that uses partitioning. Your query doesn't use the partitioning column. What is the consequence?

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

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

You are building a streaming pipeline using Dataflow to process sensor data arriving via Pub/Sub. You need to handle out-of-order data by allowing events to arrive late. Which Dataflow concept must you configure?

Which TWO of the following statements about Dataplex discovery are true? (Choose two)

Which TWO factors should you consider when choosing a GCS storage class?

You have a Looker dashboard that loads slowly. What is the first thing you should check in the 'Looker System Activity' or 'Query History'?

Which TWO of the following are GCP ingestion tools?

You need to export query results from BigQuery to a Google Sheet. What is the easiest way to do this?

You have a query that processes 500GB of data. You want to reduce the cost of this query. What is the most effective approach?

You are ingesting CSV files into BigQuery using the bq load command. The CSV files have a header row, and you want BigQuery to automatically detect the schema and skip the header. Which flags should you include?

You have noticed that your data quality tasks are failing. Which THREE of the following are potential causes for failure? (Choose three)

You have a BigQuery table that is partitioned by ingestion time. You need to reduce storage costs by automatically deleting data older than 90 days. You want to ensure that the deletion happens without manual intervention and that the partitions are completely removed. What should you do?

A data engineer needs to create a visualization in Looker Studio that shows the relationship between advertising spend and revenue for each marketing campaign. They want to quickly identify which campaigns have high spend but low revenue. Which chart type is most appropriate?

A retail analytics team runs a Looker Explore against a BigQuery table containing order line items. Analysts need a single visual that shows the average order value per country, but the underlying table stores one row per line item, so multiple rows share the same order_id. Which approach produces a correct average order value per country?

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

You need to ensure that PII (Personally Identifiable Information) in BigQuery is automatically detected and tagged across your organization. Which Dataplex feature should you enable on your Lake?

You are the data engineer for a retail company on Google Cloud. Analysts query a BigQuery table that contains 400 TB of point-of-sale records and almost always filter by transaction_date. Query costs have grown sharply because every query scans the full table. You need the most cost-effective change that reduces bytes scanned for date-filtered queries without altering the table schema. What should you do?

You have a BigQuery table containing millions of rows of web server logs. You need to run a query that filters on a timestamp column and returns only the last 24 hours of data. The table is not partitioned. What should you do to improve query performance and reduce cost for this and future similar queries?

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

You are a data engineer at a healthcare company. You need to create a Dataflow pipeline that reads from a Pub/Sub subscription and writes to BigQuery. The pipeline must handle late-arriving data and ensure exactly-once processing. You also need to minimize cost. Which of the following should you use?

A marketing analyst needs to run a one-time SQL query that joins a BigQuery table containing campaign performance data with a small CSV file stored in a Cloud Storage bucket. The CSV is updated weekly by an external partner. The analyst wants the query to always reflect the latest CSV without loading it into BigQuery each week. What should the analyst do?

You are using Cloud Scheduler to trigger a Workflows execution every hour. The Workflows definition expects an argument 'projectId' to be passed at runtime. You need to ensure the argument is provided correctly. What should you include in the Cloud Scheduler job configuration?

Which TWO are methods to secure GCS data?

A data analyst is working in a Vertex AI Workbench notebook. They want to connect to a private BigQuery dataset. How should they authenticate?

A financial analyst needs a Looker dashboard tile that shows month-over-month revenue growth as a percentage. The underlying BigQuery table stores completed transactions, and the analyst wants the tile to update without manual intervention each month. Which approach should the analyst use in Looker?

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

You are using Vertex AI Workbench. You want to install a new Python library, `seaborn`, for visualization. What is the correct way to install it in the notebook instance?

Which service should you use to ingest streaming data from mobile devices?

You are building a Looker model and want to create a measure that calculates the count of distinct customers. Which type of measure should you use?

You are using Cloud Composer to orchestrate a daily ETL pipeline. A task that normally completes in 10 minutes occasionally runs for over 2 hours due to unexpected data volume. You want to prevent this task from indefinitely blocking the workflow and ensure it fails after 30 minutes so downstream tasks can be retried or alerted. What should you configure on the task?

A data engineer must ingest change data capture streams from an on-premises PostgreSQL database into BigQuery with minimal latency and without writing custom extraction code. The source table has a primary key that updates frequently. Which Google Cloud service should be used to replicate these changes continuously?

What is the primary function of the 'Dataplex Discovery' process?

You have a dashboard in Looker Studio and you want to allow users to dynamically change the date range without editing the report. What should you add?

You have data scattered across multiple projects and need to provide a unified data governance view. What is the recommended hierarchy?

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

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

You are a data analyst at a marketing firm. You need to query a large dataset stored in BigQuery, but you want to minimize query costs. The dataset contains a column named event_time of type TIMESTAMP. Most of your queries filter on event_time for a specific day. What should you do to reduce the amount of data scanned by your queries?

You are running a Dataflow job and notice that it is consuming too much memory and crashing. How do you optimize this?

You are implementing a security strategy for your data lake. Which THREE of the following are supported ways to control access to data within a Dataplex Lake? (Choose three)

A data analyst has a Looker Studio report connected to a BigQuery table containing millions of rows. The report includes a table chart that shows aggregated sales by product category. Users complain that the report takes a long time to load. Which action should the analyst take to improve performance without changing the report's layout?

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

You are writing a complex BigQuery query and need to define a temporary table to use later in the same query. What is the most efficient syntax?

You are using Cloud Dataflow to process a batch pipeline that reads from Cloud Storage, transforms data, and writes to BigQuery. You notice that the pipeline is running slowly and want to optimize it. Which of the following should you do to improve performance?

You need to perform a complex windowing operation on streaming data in Dataflow. Which windowing strategy is best for session-based activity?

A team is migrating to Dataplex. Which TWO of the following are prerequisites for adding a BigQuery dataset as an asset to a Lake? (Choose two)

You are using Cloud Data Fusion to build a batch pipeline that reads from an on-premises Oracle database and writes to BigQuery. The pipeline must run daily and you need to ensure that only new or changed records are ingested since the last run. Which plugin feature should you configure in the source stage?

You are using Dataflow with autoscaling. What metric determines whether the worker pool scales up or down?

You need to organize your data governance strategy. Which TWO of the following are valid ways to use Dataplex Zones to improve your data organization? (Choose two)

You need to ingest IoT data into BigQuery. You need to handle messages arriving in millions per second. Which service acts as the buffer?

You are using Workflows to orchestrate a series of steps that call external HTTP APIs. One API occasionally returns a 503 error, and you want the workflow to retry that specific step with exponential backoff, but not retry on 404 errors. How should you configure the step?

A financial analytics team ingests transaction events into Pub/Sub, then uses a Dataflow streaming pipeline with a GroupByKey transform to aggregate per-account totals. The team reports that late-arriving events—sometimes hours behind due to mobile connectivity—are being dropped and never counted in the aggregates. You need the pipeline to include those late events in the correct window. What should you configure?

You are loading a daily CSV file from Cloud Storage into a BigQuery table. The file contains a header row, uses comma delimiters, and has some rows with extra trailing columns. You want the load to tolerate these malformed rows by skipping them and recording how many were skipped, without failing the whole job. Which load configuration should you use?

A user complains they cannot see a Dataplex Lake in the console. You verify they have the 'Viewer' role on the project. What is missing?

A data practitioner is building a Looker Studio report connected to a BigQuery table that contains millions of rows. The report currently returns an error indicating the query result exceeds the row limit, and stakeholders also complain that the charts take too long to render. Which two actions should the practitioner take to address these issues? (Choose two.)

Which THREE of the following are Dataflow windowing types?

Which TWO of the following are true about Dataplex assets? (Choose two)

Which THREE steps are involved in an effective Dataflow pipeline development?

You need to ingest data from an external API that requires an OAuth token. Which tool is best for executing this periodically?

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

Your analytics team stores clickstream events in Cloud Storage as newline-delimited JSON files. They want to query this data with BigQuery using SQL without loading it into native BigQuery storage, and they want the table definition to refresh automatically when new files land in the bucket. What should you configure?