Amazon DynamoDB Streams to Amazon SQS queue using Amazon EventBridge Pipes

Amazon DynamoDB Streams → Amazon EventBridge Pipes → Amazon SQS

This pattern creates an Amazon EventBridge Pipe to deliver messages from an Amazon DynamoDB Stream to Amazon SQS.

Whenever there is a change (insert, update, or delete) to an item in a DynamoDB table, a new record is added to the DynamoDB Stream. The stream captures the details of the event, and the item data.
This pattern allows you to react to changes in your DynamoDB table by filtering (optional) and delivering relevant events to an SQS queue. The EventBridge Pipe acts as a bridge between the DynamoDB Stream and the SQS queue.
Then, other services or applications can consume these events from the SQS queue.

< Back to all patterns

GitHub icon Download this pattern (.zip)

GitHub icon View this pattern on GitHub


Clone repo

git clone https://github.com/aws-samples/serverless-patterns/cd serverless-patterns/eventbridge-pipes-dynamodbstream-to-sqs-terraform

Deploy

terraform initterraform apply


Testing

See the README in the GitHub repo for detailed testing instructions.

Cleanup

terraform destroy

Created by:

Chaitanya Gummadi

Chaitanya Gummadi

Chaitanya is a Sr. Cloud Support Engineer with Amazon Web Services (AWS) based in Texas.

Follow on LinkedIn