DEA-C01 practice question 11 of 25

A telecommunications company collects network usage data throughout each day at a rate of several thousand data points each second. The company runs…

Full set: 287 questions
A telecommunications company collects network usage data throughout each day at a rate of several thousand data points each second. The company runs an application to process the usage data in real time. The company aggregates and stores the data in an Amazon Aurora DB instance. Sudden drops in network usage usually indicate a network outage. The company must be able to identify sudden drops in network usage so the company can take immediate remedial actions. Which solution will meet this requirement with the LEAST latency?
Answer options
A: Create an AWS Lambda function to query Aurora for drops in network usage. Use Amazon EventBridge to automatically invoke the Lambda function every minute.
B: Modify the processing application to publish the data to an Amazon Kinesis data stream. Create an Amazon Managed Service for Apache Flink (previously known as Amazon Kinesis Data Analytics) application to detect drops in network usage. Correct answer
C: Replace the Aurora database with an Amazon DynamoDB table. Create an AWS Lambda function to query the DynamoDB table for drops in network usage every minute. Use DynamoDB Accelerator (DAX) between the processing application and DynamoDB table.
D: Create an AWS Lambda function within the Database Activity Streams feature of Aurora to detect drops in network usage.
Correct Answer:
B. Modify the processing application to publish the data to an Amazon Kinesis data stream. Create an Amazon Managed Service for Apache Flink (previously known as Amazon Kinesis Data Analytics) application to detect drops in network usage.
Explanation

The requirement is for real-time processing with the least latency to detect sudden drops in network usage. Amazon Kinesis Data Streams is designed for high-throughput, real-time data ingestion. Amazon Managed Service for Apache Flink (formerly Kinesis Data Analytics) is purpose-built for complex, stateful stream processing with sub-second latencies. This combination provides a serverless, highly scalable architecture ideal for real-time anomaly detection on streaming data, directly meeting the low-latency requirement.

Why Incorrect

A. Polling an Aurora database every minute introduces significant latency (up to 60 seconds) and is not a real-time streaming solution.
C. This solution still relies on polling every minute, which does not meet the low-latency requirement. DAX is a cache and does not change the polling architecture.
D. Aurora Database Activity Streams are for auditing database events (like logins or queries), not for analyzing the application data being written into the tables.

References

1. Amazon Kinesis Data Analytics for Apache Flink Developer Guide. (2023). What Is Amazon Kinesis Data Analytics for Apache Flink? AWS Documentation. "You can use Kinesis Data Analytics for real-time analytics. You can process streaming data in real time and with sub-second latencies..."

2. Amazon Web Services. (2021). Streaming Data Solutions on AWS with Amazon Kinesis. AWS Whitepaper, p. 10. "Amazon Kinesis Data Analytics is the easiest way to analyze streaming data, gain actionable insights, and respond to your business and customer needs in real time."

3. Amazon Aurora User Guide. (2023). Using Database Activity Streams. AWS Documentation. "Use database activity streams to audit the activity of your DB cluster."

Scroll to Top