LeetQuiz Logo
Privacy Policy•contact@leetquiz.com
© 2025 LeetQuiz All rights reserved.
Google Professional Data Engineer

Google Professional Data Engineer

Get started today

Ultimate access to all questions.


You are operating a car factory that transmits machine measurement data as messages to a Pub/Sub topic within your Google Cloud project. You have developed a Dataflow streaming job using the Apache Beam SDK to read these messages, acknowledge their receipt to Pub/Sub, apply custom business logic within a DoFn instance, and subsequently write the processed results to BigQuery. Your objective is to ensure that any message failing due to business logic errors is redirected to a separate Pub/Sub topic dedicated to monitoring and alerting. How should you accomplish this?

Exam-Like



Powered ByGPT-5