DEA-C01 practice question 7 of 25

A company has a data processing pipeline that includes several dozen steps. The data processing pipeline needs to send alerts in real time when a…

Full set: 287 questions
A company has a data processing pipeline that includes several dozen steps. The data processing pipeline needs to send alerts in real time when a step fails or succeeds. The data processing pipeline uses a combination of Amazon S3 buckets, AWS Lambda functions, and AWS Step Functions state machines. A data engineer needs to create a solution to monitor the entire pipeline. Which solution will meet these requirements?
Answer options
A: Configure the Step Functions state machines to store notifications in an Amazon S3 bucket when the state machines finish running. Enable S3 event notifications on the S3 bucket.
B: Configure the AWS Lambda functions to store notifications in an Amazon S3 bucket when the state machines finish running. Enable S3 event notifications on the S3 bucket.
C: Use AWS CloudTrail to send a message to an Amazon Simple Notification Service (Amazon SNS) topic that sends notifications when a state machine fails to run or succeeds to run.
D: Configure an Amazon EventBridge rule to react when the execution status of a state machine changes. Configure the rule to send a message to an Amazon Simple Notification Service (Amazon SNS) topic that sends notifications. Correct answer
Correct Answer:
D. Configure an Amazon EventBridge rule to react when the execution status of a state machine changes. Configure the rule to send a message to an Amazon Simple Notification Service (Amazon SNS) topic that sends notifications.
Explanation

AWS Step Functions natively integrates with Amazon EventBridge, emitting events for every execution and state transition (e.g., SUCCEEDED, FAILED). This is the most direct and efficient way to monitor the entire pipeline. By creating an EventBridge rule that filters for specific status changes from the target state machine, you can trigger an action, such as publishing a message to an Amazon SNS topic. This provides real-time, centralized notifications for the entire workflow's status without requiring custom code within the pipeline's individual steps.

Why Incorrect

A. This method is indirect, adds unnecessary components (S3), and only provides a notification when the entire state machine finishes, not for individual step failures in real time.
B. Requiring each Lambda function to write notifications is decentralized, hard to maintain, and does not provide a holistic view of the Step Functions orchestrator itself.
C. AWS CloudTrail is designed for auditing API activity and has inherent latency. It is not the appropriate service for real-time operational monitoring and alerting on state machine status.

References

1. AWS Step Functions Developer Guide. (2023). Monitoring with Amazon EventBridge. This guide explicitly details the process: "You can create an Amazon EventBridge rule that triggers when a state machine execution changes status... For example, you can create a rule that sends a notification to an Amazon SNS topic when an execution fails." AWS. Retrieved from https://docs.aws.amazon.com/step-functions/latest/dg/cw-events.html

2. Amazon EventBridge User Guide. (2023). Events from AWS services. This document lists AWS Step Functions as a native event source for EventBridge, confirming the direct integration. AWS. Retrieved from https://docs.aws.amazon.com/eventbridge/latest/userguide/events-service-events.html

Scroll to Top