Simple pattern that sends events from DynamoDB Stream to SQS using EventBridge Pipes. Implemented with CDK using Python.
Whenever there is an change in a item of the DynamoDB table, a message about the change and item will be available in DynamoDB Stream.
EventBridge Pipe polls these messages in DynamoDB stream. When the messages are available, Pipe first filter them based on the filter criteria provided. Then, the matched messages are sent to the target SQS.
< Back to all patterns
Clone repo
git clone https://github.com/aws-samples/serverless-patterns/cd eventbridge-pipes-dynamodbstream-to-sqs-cdk-pythonDeploy
cdk deployTesting
See the README in the GitHub repo for detailed testing instructions.
Cleanup
Delete the stack:
cdk destroy.Created by:
