Simple pattern that split messages in a SQS queue into multiple SQS queues using EventBridge Pipe and Event Bus. Implemented using CDK using Python.
EventBridge Pipe polls messages in source SQS queue. Then using enrichment Lambda function, it extract the original payload.
Then the messages is sent to the Event Bus. Two SQS queues are set as targets and based on the 'type' value on the orignial message, it will be delivered to the respective target queue.
< Back to all patterns
Clone repo
git clone https://github.com/aws-samples/serverless-patterns/cd serverless-patterns/eventbridge-pipes-sqs-to-multiple-sqsDeploy
cdk deployTesting
See the README in the GitHub repo for detailed testing instructions.
Cleanup
Delete the stack:
cdk destroy.Created by:
