Description
With tumbling windows, you can calculate aggregate values in near-real time for Kinesis data streams and DynamoDB streams. Unlike existing stream-based invocations, state can be passed forward by Lamb ...
Summary
- In this blog post, I explain how this feature works with Kinesis Data Streams and DynamoDB Streams, together with example use-cases.
- For example, in Amazon Kinesis Data Firehose, a Lambda function transforms the current batch of records with no information or state from previous batches.
- The third tumbling window invokes the Lambda function with a state value of 18 and the next window of values.
- This function code processes the incoming event to aggregate a sales attribute, and return this aggregated result in a state object.