Google Professional Data Engineer Practice Test 40
Question 390
After applying the change, the team re-examines this condition: A finance warehouse needs recoverable reporting after regional disruption but keeps its only critical dataset in one region. Which result BEST verifies the improvement?
- A regional failover exercise meets RPO/RTO and produces no material missing or duplicated transactions.
- A zonal failover test resumes data ingestion within the documented RTO.
- An isolated regional outage drill restores a representative report from the approved alternate data copy.
- Rebuilt totals match trusted controls with auditable corrections and no duplicates.
Explanation
Correct Answer
C:An isolated regional outage drill restores a representative report from the approved alternate data copy. This measures the intended corrected behavior rather than only confirming a setting. Implemented action: Design and test a compatible cross-location recovery approach consistent with regulation. Analytical recovery requires independently retained copies and known restore procedures that meet policy.
Incorrect Answers
A:A regional failover exercise meets RPO/RTO and produces no material missing or duplicated transactions. This addresses a different situation: A critical Pub/Sub-to-warehouse flow has a secondary-region deployment template but no retained state, failover routing, or test exercise. The current scenario instead calls for the more directly applicable verification result: An isolated regional outage drill restores a representative report from the approved alternate data copy. The reason is that analytical recovery requires independently retained copies and known restore procedures that meet policy.
B:A zonal failover test resumes data ingestion within the documented RTO. This addresses a different situation: A production relational data source resides on a single-zone Cloud SQL instance and a zone outage stops all ingestion. The current scenario instead calls for the more directly applicable verification result: An isolated regional outage drill restores a representative report from the approved alternate data copy. The reason is that analytical recovery requires independently retained copies and known restore procedures that meet policy.
D:Rebuilt totals match trusted controls with auditable corrections and no duplicates. This addresses a different situation: An upstream vendor accidentally publishes a corrupted schema version and downstream totals become wrong before anyone notices. The current scenario instead calls for the more directly applicable verification result: An isolated regional outage drill restores a representative report from the approved alternate data copy. The reason is that analytical recovery requires independently retained copies and known restore procedures that meet policy.
Question 391
A Google Cloud architecture review finds: A service provider exposes aggregate service quality metrics to customers but must not reveal individual employee work records. Which principle BEST explains the underlying data-engineering risk?
- Authorized views can expose filtered or aggregated analytical data subject to correct permissions.
- Data publication should distinguish certified, governed outputs from exploratory drafts.
- Row-level security can enforce tenant-scoped access when identity and policy design are correct.
- Governed BigQuery sharing can provide authorized access to publisher datasets through supported sharing models.
Explanation
Correct Answer
A:Authorized views can expose filtered or aggregated analytical data subject to correct permissions. This principle identifies the relevant workload or governance requirement. The engineer should first examine: Inspect SQL aggregation grain, underlying table security, authorized view grants, and customer groups. A focused corrective action is: Publish a reviewed aggregate view with narrowly scoped dataset authorization.
Incorrect Answers
B:Data publication should distinguish certified, governed outputs from exploratory drafts. This addresses a different situation: A finance department publishes unreviewed experiment tables to the company-wide BI directory and consumers treat them as financial statements. The current scenario instead calls for the more directly applicable principle: Authorized views can expose filtered or aggregated analytical data subject to correct permissions. The reason is that authorized views can expose filtered or aggregated analytical data subject to correct permissions.
C:Row-level security can enforce tenant-scoped access when identity and policy design are correct. This addresses a different situation: A SaaS analytics platform hosts multiple tenant records in one BigQuery table, and users may see only their organization's rows. The current scenario instead calls for the more directly applicable principle: Authorized views can expose filtered or aggregated analytical data subject to correct permissions. The reason is that authorized views can expose filtered or aggregated analytical data subject to correct permissions.
D:Governed BigQuery sharing can provide authorized access to publisher datasets through supported sharing models. This addresses a different situation: Two companies want to share selected curated BigQuery datasets without copying unrestricted source projects into each tenant. The current scenario instead calls for the more directly applicable principle: Authorized views can expose filtered or aggregated analytical data subject to correct permissions. The reason is that authorized views can expose filtered or aggregated analytical data subject to correct permissions.
Question 392
The data engineering team must correct this issue: A yearly backfill invokes all daily dependent tasks concurrently, while downstream aggregation assumes every day is already complete. Which controlled engineering action is MOST appropriate?
- Configure the intended time zone and test scheduled execution across relevant date transitions.
- Design tasks with stable run identifiers and safe retries or external deduplication.
- Use approved Dataform release configurations and workflow schedules bound to reviewed code.
- Create a parameterized backfill DAG with ordered readiness checks and bounded parallelism.
Explanation
Correct Answer
D:Create a parameterized backfill DAG with ordered readiness checks and bounded parallelism. This addresses the specific problem while respecting business and technical constraints. Validate it by checking: An annual report is published only after all prerequisite historical partitions reconcile. Backfill workflows need dependency awareness and capacity controls.
Incorrect Answers
A:Configure the intended time zone and test scheduled execution across relevant date transitions. This addresses a different situation: A daily report must run at 08:00 business time, but the scheduler is configured in UTC and shifts unexpectedly after regional daylight changes. The current scenario instead calls for the more directly applicable engineering action: Create a parameterized backfill DAG with ordered readiness checks and bounded parallelism. The reason is that backfill workflows need dependency awareness and capacity controls.
B:Design tasks with stable run identifiers and safe retries or external deduplication. This addresses a different situation: An Airflow DAG reruns after scheduler recovery and reissues the same external billing update twice. The current scenario instead calls for the more directly applicable engineering action: Create a parameterized backfill DAG with ordered readiness checks and bounded parallelism. The reason is that backfill workflows need dependency awareness and capacity controls.
C:Use approved Dataform release configurations and workflow schedules bound to reviewed code. This addresses a different situation: A production ELT workflow pulls arbitrary local workspace changes without approvals, creating nondeterministic table definitions. The current scenario instead calls for the more directly applicable engineering action: Create a parameterized backfill DAG with ordered readiness checks and bounded parallelism. The reason is that backfill workflows need dependency awareness and capacity controls.
Question 393
A Google Cloud architecture review finds: A daily fact table receives corrections, but each load recomputes every historical year and causes excessive query cost. Which principle BEST explains the underlying data-engineering risk?
- Historical warehouse analysis may require time-versioned dimension attributes.
- Warehouse architecture should separate workloads or allocate capacity according to business priorities.
- Precomputed summary structures can improve repeated analytical response time where refresh limits and query patterns fit.
- Incremental transformations should process only changed partitions where correctness permits.
Explanation
Correct Answer
D:Incremental transformations should process only changed partitions where correctness permits. This principle identifies the relevant workload or governance requirement. The engineer should first examine: Inspect change-watermarks, partition dates, correction frequency, and merge costs. A focused corrective action is: Build an incremental partition-aware load with validated late-change reconciliation.
Incorrect Answers
A:Historical warehouse analysis may require time-versioned dimension attributes. This addresses a different situation: Customer account tiers change over time but year-old invoices must be reported using the tier effective at the invoice date. The current scenario instead calls for the more directly applicable principle: Incremental transformations should process only changed partitions where correctness permits. The reason is that incremental transformations should process only changed partitions where correctness permits.
B:Warehouse architecture should separate workloads or allocate capacity according to business priorities. This addresses a different situation: Interactive analysts share BigQuery capacity with long overnight transformations, causing unpredictable daytime dashboard latencies. The current scenario instead calls for the more directly applicable principle: Incremental transformations should process only changed partitions where correctness permits. The reason is that incremental transformations should process only changed partitions where correctness permits.
C:Precomputed summary structures can improve repeated analytical response time where refresh limits and query patterns fit. This addresses a different situation: A popular dashboard repeatedly computes the same large daily summary with strict latency goals, while raw transactional records remain necessary for detail drill-down. The current scenario instead calls for the more directly applicable principle: Incremental transformations should process only changed partitions where correctness permits. The reason is that incremental transformations should process only changed partitions where correctness permits.
Question 394
A Google Cloud architecture review finds: A global enterprise distributes data ownership to regional teams but needs one standard for naming, retention, and access requests. Which principle BEST explains the underlying data-engineering risk?
- Multi-engine data platforms need consistent access enforcement and auditable object-to-table mapping.
- Federated data platform governance balances domain ownership with shared discovery and interoperability policies.
- Federated governance needs clear decision rights, shared policies, and local stewardship.
- A central catalog and policy taxonomy can help govern multiple analytical storage systems.
Explanation
Correct Answer
C:Federated governance needs clear decision rights, shared policies, and local stewardship. This principle identifies the relevant workload or governance requirement. The engineer should first examine: Interview regional data owners and examine access approvals, standards, and escalation paths. A focused corrective action is: Establish federated roles and a platform operating model with common policies and domain exceptions.
Incorrect Answers
A:Multi-engine data platforms need consistent access enforcement and auditable object-to-table mapping. This addresses a different situation: Data teams use Cloud Storage for open formats and BigQuery for SQL, but each engine applies incompatible permissions to the same sensitive records. The current scenario instead calls for the more directly applicable principle: Federated governance needs clear decision rights, shared policies, and local stewardship. The reason is that federated governance needs clear decision rights, shared policies, and local stewardship.
B:Federated data platform governance balances domain ownership with shared discovery and interoperability policies. This addresses a different situation: Finance and logistics teams publish data independently, but a central team imposes one schema that ignores both domains' definitions. The current scenario instead calls for the more directly applicable principle: Federated governance needs clear decision rights, shared policies, and local stewardship. The reason is that federated governance needs clear decision rights, shared policies, and local stewardship.
D:A central catalog and policy taxonomy can help govern multiple analytical storage systems. This addresses a different situation: A company acquires another business and wants consistent discovery and access classification across existing BigQuery and Cloud Storage assets. The current scenario instead calls for the more directly applicable principle: Federated governance needs clear decision rights, shared policies, and local stewardship. The reason is that federated governance needs clear decision rights, shared policies, and local stewardship.
Question 395
A Google Cloud data engineer is addressing: A pipeline triggers an invoice-export API and Airflow retries the task after a timeout, sending the same invoice twice. Which TWO complementary actions should the team take? Select TWO answers.
- Add supported readiness checks and explicit directed dependencies to the Composer workflow.
- Use stable idempotency keys or transactional checkpoints before retrying external exports.
- Inspect task retry settings, API response behavior, business keys, and outbox records.
- Add a reviewed CI pipeline with unit/integration tests and controlled Dataflow template promotion.
- Inspect template options, bucket identifiers, worker identities, and region restrictions.
Explanation
Correct Answers
B:Use stable idempotency keys or transactional checkpoints before retrying external exports. This is the applicable controlled engineering response. Its complementary step is: Inspect task retry settings, API response behavior, business keys, and outbox records. Together they address: Orchestration retries must respect the idempotency of downstream actions.
C:Inspect task retry settings, API response behavior, business keys, and outbox records. This is the applicable diagnostic investigation. Its complementary step is: Use stable idempotency keys or transactional checkpoints before retrying external exports. Together they address: Orchestration retries must respect the idempotency of downstream actions.
Incorrect Answers
A:Add supported readiness checks and explicit directed dependencies to the Composer workflow. This could be useful for another system: An Airflow DAG launches a billing aggregation before its source partition arrives, producing empty reports that appear successful. For this situation, the necessary paired decisions are to examine (Inspect task retry settings, API response behavior, business keys, and outbox records.) and to implement (Use stable idempotency keys or transactional checkpoints before retrying external exports.).
D:Add a reviewed CI pipeline with unit/integration tests and controlled Dataflow template promotion. This could be useful for another system: Developers change Dataflow transform logic directly in production with no version tags or regression tests. For this situation, the necessary paired decisions are to examine (Inspect task retry settings, API response behavior, business keys, and outbox records.) and to implement (Use stable idempotency keys or transactional checkpoints before retrying external exports.).
E:Inspect template options, bucket identifiers, worker identities, and region restrictions. This could be useful for another system: The same Dataflow template should run in staging and production but contains hardcoded staging bucket names and service-account references. For this situation, the necessary paired decisions are to examine (Inspect task retry settings, API response behavior, business keys, and outbox records.) and to implement (Use stable idempotency keys or transactional checkpoints before retrying external exports.).
Question 396
A design review evaluates this situation: A production ELT workflow pulls arbitrary local workspace changes without approvals, creating nondeterministic table definitions. Which shortcut should the team MOST specifically avoid?
- Disable all retries to hide duplicate side effects without solving recovery.
- Hardcode one UTC offset and assume all regions have no daylight changes.
- Run every developer's working copy directly against production on a fixed schedule.
- Retry every request forever at full rate regardless of response code or side effect.
Explanation
Correct Answer
C:Run every developer's working copy directly against production on a fixed schedule. This is the unsafe shortcut directly relevant to the stated system. A better approach is: Use approved Dataform release configurations and workflow schedules bound to reviewed code. Why: Versioned compilation and scheduled production execution improve repeatability and change control.
Incorrect Answers
A:Disable all retries to hide duplicate side effects without solving recovery. This addresses a different situation: An Airflow DAG reruns after scheduler recovery and reissues the same external billing update twice. The current scenario instead calls for the more directly applicable unsafe shortcut: Run every developer's working copy directly against production on a fixed schedule. The reason is that versioned compilation and scheduled production execution improve repeatability and change control.
B:Hardcode one UTC offset and assume all regions have no daylight changes. This addresses a different situation: A daily report must run at 08:00 business time, but the scheduler is configured in UTC and shifts unexpectedly after regional daylight changes. The current scenario instead calls for the more directly applicable unsafe shortcut: Run every developer's working copy directly against production on a fixed schedule. The reason is that versioned compilation and scheduled production execution improve repeatability and change control.
D:Retry every request forever at full rate regardless of response code or side effect. This addresses a different situation: A managed API intermittently returns 503, causing a multi-step data export workflow to fail permanently without preserving state. The current scenario instead calls for the more directly applicable unsafe shortcut: Run every developer's working copy directly against production on a fixed schedule. The reason is that versioned compilation and scheduled production execution improve repeatability and change control.
Question 397
After applying the change, the team re-examines this condition: A research institute has hundreds of terabytes on isolated storage and cannot upload the first copy within its migration window. Which result BEST verifies the improvement?
- A representative Spark job produces reconciled output and meets its batch deadline.
- A manifest confirms transferred object counts and checksums within the cutover window.
- A test mutation during backfill appears once in the destination after catch-up.
- The migrated ledger matches required currency totals and precision across sampled periods.
Explanation
Correct Answer
B:A manifest confirms transferred object counts and checksums within the cutover window. This measures the intended corrected behavior rather than only confirming a setting. Implemented action: Evaluate an approved Transfer Appliance or equivalent controlled initial bulk-transfer approach. Large data transfers must consider achievable network throughput, physical transfer options, and integrity.
Incorrect Answers
A:A representative Spark job produces reconciled output and meets its batch deadline. This addresses a different situation: A batch Hadoop estate has custom Spark jobs and HDFS storage tightly coupled to aging servers. The current scenario instead calls for the more directly applicable verification result: A manifest confirms transferred object counts and checksums within the cutover window. The reason is that large data transfers must consider achievable network throughput, physical transfer options, and integrity.
C:A test mutation during backfill appears once in the destination after catch-up. This addresses a different situation: A retail database migration captures historical tables but fails to process updates made after the initial snapshot. The current scenario instead calls for the more directly applicable verification result: A manifest confirms transferred object counts and checksums within the cutover window. The reason is that large data transfers must consider achievable network throughput, physical transfer options, and integrity.
D:The migrated ledger matches required currency totals and precision across sampled periods. This addresses a different situation: A historical financial ledger migration matches table row counts but contains changed decimal precision in several high-value transactions. The current scenario instead calls for the more directly applicable verification result: A manifest confirms transferred object counts and checksums within the cutover window. The reason is that large data transfers must consider achievable network throughput, physical transfer options, and integrity.
Question 398
After applying the change, the team re-examines this condition: A partner shares daily updates while an organization copies older archives into a new Cloud Storage lake. Which result BEST verifies the improvement?
- Post-cutover row and transaction checks agree and application downtime meets its objective.
- The migrated ledger matches required currency totals and precision across sampled periods.
- A file modified during migration is represented at its intended final version exactly once.
- A manifest confirms transferred object counts and checksums within the cutover window.
Explanation
Correct Answer
C:A file modified during migration is represented at its intended final version exactly once. This measures the intended corrected behavior rather than only confirming a setting. Implemented action: Create a verified backfill manifest and idempotent incremental import with distinct landing paths. Staged migration must track initial backfill and incremental deltas using durable cursors or manifests.
Incorrect Answers
A:Post-cutover row and transaction checks agree and application downtime meets its objective. This addresses a different situation: An enterprise migrates a high-write transactional database to Google Cloud and cannot afford a long source freeze during cutover. The current scenario instead calls for the more directly applicable verification result: A file modified during migration is represented at its intended final version exactly once. The reason is that staged migration must track initial backfill and incremental deltas using durable cursors or manifests.
B:The migrated ledger matches required currency totals and precision across sampled periods. This addresses a different situation: A historical financial ledger migration matches table row counts but contains changed decimal precision in several high-value transactions. The current scenario instead calls for the more directly applicable verification result: A file modified during migration is represented at its intended final version exactly once. The reason is that staged migration must track initial backfill and incremental deltas using durable cursors or manifests.
D:A manifest confirms transferred object counts and checksums within the cutover window. This addresses a different situation: A research institute has hundreds of terabytes on isolated storage and cannot upload the first copy within its migration window. The current scenario instead calls for the more directly applicable verification result: A file modified during migration is represented at its intended final version exactly once. The reason is that staged migration must track initial backfill and incremental deltas using durable cursors or manifests.
Question 399
Before modifying the data platform, the team observes: A daily report must run at 08:00 business time, but the scheduler is configured in UTC and shifts unexpectedly after regional daylight changes. Which evidence should the engineer examine FIRST?
- Inspect repository branch, compilation version, release configuration, and invocation logs.
- Inspect Cloud Scheduler timezone, cron expression, daylight rules, and report SLA.
- Inspect HTTP status patterns, retry policy, workflow state, and downstream idempotency.
- Examine task graph, partition completeness, retries, and downstream data freshness.
Explanation
Correct Answer
B:Inspect Cloud Scheduler timezone, cron expression, daylight rules, and report SLA. This evidence directly tests the uncertain part of the described system. Scheduled workloads need explicit business time zones and calendar semantics. A controlled response is: Configure the intended time zone and test scheduled execution across relevant date transitions.
Incorrect Answers
A:Inspect repository branch, compilation version, release configuration, and invocation logs. This addresses a different situation: A production ELT workflow pulls arbitrary local workspace changes without approvals, creating nondeterministic table definitions. The current scenario instead calls for the more directly applicable investigation: Inspect Cloud Scheduler timezone, cron expression, daylight rules, and report SLA. The reason is that scheduled workloads need explicit business time zones and calendar semantics.
C:Inspect HTTP status patterns, retry policy, workflow state, and downstream idempotency. This addresses a different situation: A managed API intermittently returns 503, causing a multi-step data export workflow to fail permanently without preserving state. The current scenario instead calls for the more directly applicable investigation: Inspect Cloud Scheduler timezone, cron expression, daylight rules, and report SLA. The reason is that scheduled workloads need explicit business time zones and calendar semantics.
D:Examine task graph, partition completeness, retries, and downstream data freshness. This addresses a different situation: A yearly backfill invokes all daily dependent tasks concurrently, while downstream aggregation assumes every day is already complete. The current scenario instead calls for the more directly applicable investigation: Inspect Cloud Scheduler timezone, cron expression, daylight rules, and report SLA. The reason is that scheduled workloads need explicit business time zones and calendar semantics.
Question 400
A Google Cloud data engineer is addressing: A recurring transformation runs under the credentials of a departed analyst and begins failing when the account is disabled. Which TWO complementary actions should the team take? Select TWO answers.
- Publish a tested parameterized template with approved environment configuration.
- Inspect scheduled-query owner, credential scope, destination permissions, and alert routing.
- Use a suitable Google Cloud Workflows definition for the small stateful service chain.
- Move scheduled execution to an approved service identity or supported transfer owner with monitoring.
- Inspect DAG tasks, task dependencies, partition sensors, and success criteria.
Explanation
Correct Answers
B:Inspect scheduled-query owner, credential scope, destination permissions, and alert routing. This is the applicable diagnostic investigation. Its complementary step is: Move scheduled execution to an approved service identity or supported transfer owner with monitoring. Together they address: Production scheduling should use maintained workload identities and explicit ownership.
D:Move scheduled execution to an approved service identity or supported transfer owner with monitoring. This is the applicable controlled engineering response. Its complementary step is: Inspect scheduled-query owner, credential scope, destination permissions, and alert routing. Together they address: Production scheduling should use maintained workload identities and explicit ownership.
Incorrect Answers
A:Publish a tested parameterized template with approved environment configuration. This could be useful for another system: The same Dataflow template should run in staging and production but contains hardcoded staging bucket names and service-account references. For this situation, the necessary paired decisions are to examine (Inspect scheduled-query owner, credential scope, destination permissions, and alert routing.) and to implement (Move scheduled execution to an approved service identity or supported transfer owner with monitoring.).
C:Use a suitable Google Cloud Workflows definition for the small stateful service chain. This could be useful for another system: A lightweight pipeline calls several managed service APIs in order with retry rules, but the team proposes maintaining an entire Airflow deployment for one request chain. For this situation, the necessary paired decisions are to examine (Inspect scheduled-query owner, credential scope, destination permissions, and alert routing.) and to implement (Move scheduled execution to an approved service identity or supported transfer owner with monitoring.).
E:Inspect DAG tasks, task dependencies, partition sensors, and success criteria. This could be useful for another system: An Airflow DAG launches a billing aggregation before its source partition arrives, producing empty reports that appear successful. For this situation, the necessary paired decisions are to examine (Inspect scheduled-query owner, credential scope, destination permissions, and alert routing.) and to implement (Move scheduled execution to an approved service identity or supported transfer owner with monitoring.).