Using serverless framework: Very good blog with examples emailUsersWhenJobComplete: handler: src/emailUsersWhenJobComplete.handler events: – stream: type: dynamodb arn: ${construct:batchJobs.tableStreamArn} filterPatterns: –
Tag: stream
Reprocess AWS DB Stream
Note: DLQ for failed lambda invokation stores stream information, not the record itself Solution: You need to call get-shard-iterator, and then
AWS Stream Batch Size and Batch Window
DynamicDB and Kinesis stream serverless settings Blog on parallel processing