Part of the codecentric blog post "Processing protocol buffers messages with AWS IoT Core"
- Kinesis Data Stream - buffer incoming MQTT protobuf messages and hand them over to Lambda function
- Lambda Function - de-serialize protobuf and store to DynamoDB
- DynamoDB table - storage for de-serializes messages
- Policies and permissions
npm install
npm run build
npx cdk bootstrap aws://your-account-id/your-region
npx cdk synth
npx cdk deploy
npm run build
compile typescript to jsnpm run watch
watch for changes and compilenpm run test
perform the jest unit testscdk deploy
deploy this stack to your default AWS account/regioncdk diff
compare deployed stack with current statecdk synth
emits the synthesized CloudFormation templatecdk destroy
destroy created resources to avoid incurring any costscdk bootstrap aws://your-account-id/your-region
deploys the toolkit stack