DAS-C01 · Question #59
A regional energy company collects voltage data from sensors attached to buildings. To address any known dangerous conditions, the company wants to be alerted when a sequence of two voltage drops is…
The correct answer is D. Create an Amazon Kinesis data stream to capture the incoming sensor data and create another. This scenario requires stateful, time-windowed complex event processing (detecting a specific pattern: spike → two drops within 10 minutes) on a real-time stream. Amazon Kinesis Data Streams is purpose-built for low-latency, real-time data ingestion at scale and is fully…
Question
A regional energy company collects voltage data from sensors attached to buildings. To address any known dangerous conditions, the company wants to be alerted when a sequence of two voltage drops is detected within 10 minutes of a voltage spike at the same building. It is important to ensure that all messages are delivered as quickly as possible. The system must be fully managed and highly available. The company also needs a solution that will automatically scale up as it covers additional cites with this monitoring feature. The alerting system is subscribed to an Amazon SNS topic for remediation. Which solution meets these requirements?
Options
- ACreate an Amazon Managed Streaming for Kafka cluster to ingest the data, and use an Apache
- BCreate a REST-based web service using Amazon API Gateway in front of an AWS Lambda
- CCreate an Amazon Kinesis Data Firehose delivery stream to capture the incoming sensor data.
- DCreate an Amazon Kinesis data stream to capture the incoming sensor data and create another
How the community answered
(61 responses)- A5% (3)
- B11% (7)
- C2% (1)
- D82% (50)
Explanation
This scenario requires stateful, time-windowed complex event processing (detecting a specific pattern: spike → two drops within 10 minutes) on a real-time stream. Amazon Kinesis Data Streams is purpose-built for low-latency, real-time data ingestion at scale and is fully managed and highly available. Pairing it with Amazon Kinesis Data Analytics (Apache Flink) allows you to define time-window queries that detect the exact voltage-spike-then-two-drops pattern within a 10-minute window per building, then publish an alert to the SNS topic. Kinesis scales automatically as more cities are onboarded. Option A (MSK + Apache Kafka Streams) could technically work but MSK is not as operationally simple or auto-scaling as Kinesis. Option B (API Gateway + Lambda) is a request/response model, not suited for stateful streaming pattern detection. Option C (Kinesis Data Firehose) is a delivery service to destinations like S3 or Redshift - it has no capability for real-time CEP (complex event processing) or time-window analysis.
Topics
Community Discussion
No community discussion yet for this question.