5: Kinesis + Lambda
·1 min
Table of Contents
Architecture
- Custom application triggers data stream
- Data stream feeds to lambda
- (Need executon role for lambda)
- Stream out from Lambda to CloudWatch
Steps
- Write records to streams
- Lambda polls the stream. When new records detected…
- Invoke lambda
- Assume the execution role specified
Lambda Function
- Needs execution role to read kinesis, write logs to CloudWatch
Input File
Are “Kinesis Data Streams” input or output?
- It often acts as both input and output