Question

A retail company ingests clickstream events into an Amazon Kinesis Data Stream. The analytics team needs to compute continuous, tumbling-window aggregations (such as page views per product every minute) and push the results to a live operational dashboard with minimal latency. They want a solution that requires no server management and can process the stream in real time using SQL or Apache Flink. Which approach best meets these requirements?

Accepted Answer

Use Amazon Managed Service for Apache Flink (Kinesis Data Analytics) to read from the stream, perform windowed aggregations, and emit results to the dashboard sink

Answer

Configure Amazon Kinesis Data Firehose to buffer events and deliver them to Amazon S3, then run scheduled Amazon Athena queries to populate the dashboard

Answer

Trigger an AWS Lambda function on each record and write raw events to Amazon DynamoDB, then have the dashboard scan the table every minute

Answer

Load the stream into Amazon Redshift using COPY and run materialized views refreshed on a schedule to compute the aggregations