New serverless pattern - eventbridge-pipes-sqs-to-dynamodb by mscarimb · Pull Request #2950 · aws-samples/serverless-patterns

mscarimb · 2026-02-12T13:35:26Z

Issue #, if available:

Description of changes:
New serverless pattern that sends messages from SQS queue to DynamoDB table via API Gateway using EventBridge Pipes. Implemented with CDK using Python.

By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.

marcojahn

Hello @mscarimb, thank you for your contribution. I've added a few requests for change. Please review.

marcojahn · 2026-02-19T16:21:59Z

...pipes-sqs-to-dynamodb/eventbridge_pipes_sqs_to_dynamodb/eventbridge_pipes_sqs_to_dynamodb.py

+
+class EventbridgePipesSqsToDynamodb(Stack):
+
+    def __init__(self, scope: Construct, construct_id: str, env: cdk.Environment, **kwargs) -> None:


Suggested change

def __init__(self, scope: Construct, construct_id: str, env: cdk.Environment, **kwargs) -> None:

def __init__(self, scope: Construct, construct_id: str, env: cdk.Environment = None, **kwargs) -> None:

I got

❯ cdk synth Traceback (most recent call last): File ".../serverless-patterns-guardian/serverless-patterns/eventbridge-pipes-sqs-to-dynamodb/app.py", line 7, in <module> stack = EventbridgePipesSqsToDynamodb(app, "EventbridgePipesSqsToDynamodb") ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ File ".../serverless-patterns-guardian/serverless-patterns/eventbridge-pipes-sqs-to-dynamodb/.venv/lib/python3.12/site-packages/jsii/_runtime.py", line 118, in __call__ inst = super(JSIIMeta, cast(JSIIMeta, cls)).__call__(*args, **kwargs) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ TypeError: EventbridgePipesSqsToDynamodb.__init__() missing 1 required positional argument: 'env' python3 app.py: Subprocess exited with error 1

marcojahn · 2026-02-19T16:24:24Z

eventbridge-pipes-sqs-to-dynamodb/README.md

With the complexity of the architecture (number of services), pls add a brief architecture diagram visualizing the flow/architecture.

No architecture diagram showing the flow from SQS → EventBridge Pipes → API Gateway → DynamoDB.

marcojahn · 2026-02-19T16:26:44Z

eventbridge-pipes-sqs-to-dynamodb/README.md

@@ -0,0 +1,79 @@
+# SQS to DynamoDB using EventBridge Pipes with API Gateway and CDK/Python


Suggested change

# SQS to DynamoDB using EventBridge Pipes with API Gateway and CDK/Python

# Amazon SQS to Amazon DynamoDB using Amazon EventBridge Pipes with Amazon API Gateway and CDK/Python

marcojahn · 2026-02-19T16:27:00Z

eventbridge-pipes-sqs-to-dynamodb/example-pattern.json

+    "resources": {
+      "bullets": [
+        {
+          "text": "Amazon Simple Queue Service",


Suggested change

"text": "Amazon Simple Queue Service",

"text": "Amazon SQS",

marcojahn · 2026-02-19T16:27:39Z

eventbridge-pipes-sqs-to-dynamodb/example-pattern.json

@@ -0,0 +1,65 @@
+{
+    "title": "SQS to DynamoDB using EventBridge Pipes with API Gateway and CDK Python",


Update the title with full qualified Services names as in readme.md.
Potential rewrite needed - 75 characters limit in the title

marcojahn · 2026-02-19T16:28:06Z

eventbridge-pipes-sqs-to-dynamodb/README.md

+
+This pattern will send messages from an SQS queue to a DynamoDB table via API Gateway using EventBridge Pipes.
+
+Learn more about this pattern at Serverless Land Patterns: https://serverlessland.com/patterns/eventbridge-pipes-sqs-to-dynamodb


Suggested change

Learn more about this pattern at Serverless Land Patterns: https://serverlessland.com/patterns/eventbridge-pipes-sqs-to-dynamodb

Learn more about this pattern at Serverless Land Patterns: [https://serverlessland.com/patterns/eventbridge-pipes-sqs-to-dynamodb](https://serverlessland.com/patterns/eventbridge-pipes-sqs-to-dynamodb)

marcojahn · 2026-02-19T16:32:02Z

eventbridge-pipes-sqs-to-dynamodb/README.md

+        --message-body '{"Message": "{\"content\":\"Test message\",\"params\":{\"name\":\"Mario\",\"surname\":\"Rossi\"}}"}'
+```
+
+When you check the DynamoDB table, you can see the entry with all the attributes parsed by API Gateway.


Suggested change

When you check the DynamoDB table, you can see the entry with all the attributes parsed by API Gateway.

Navigate to [AWS Console DynamoDB Tables](https://eu-central-1.console.aws.amazon.com/dynamodbv2/home?#tables) and check for a table with name `Audit-Table`.

When you check the DynamoDB table, you can see the entry with all the attributes parsed by API Gateway.

Add this command to have a fully bash based testing cycle. Users can switch to AWS Console at any times.

aws dynamodb scan --table-name Audit-Table

marcojahn · 2026-02-19T16:36:14Z

eventbridge-pipes-sqs-to-dynamodb/README.md

+
+## Testing
+
+Once this stack is deployed in your AWS account, copy the SQS queue name value from the output.


You can update with a bash script getting the full queue url/arn. Pls add this to your testing manual

aws sqs list-queues --query 'QueueUrls[?contains(@, `EntryPointToEventbridgePipe`)]'

marcojahn · 2026-02-19T16:36:56Z

eventbridge-pipes-sqs-to-dynamodb/README.md

+```sh
+    aws sqs send-message \
+        --queue-url "https://sqs.<region-id>.amazonaws.com/<account-id>/<queue-name>" \
+        --message-body '{"Message": "{\"content\":\"Test message\",\"params\":{\"name\":\"Mario\",\"surname\":\"Rossi\"}}"}'
+```


Suggested change

```sh

aws sqs send-message \

--queue-url "https://sqs.<region-id>.amazonaws.com/<account-id>/<queue-name>" \

--message-body '{"Message": "{\"content\":\"Test message\",\"params\":{\"name\":\"Mario\",\"surname\":\"Rossi\"}}"}'

```

```sh

aws sqs send-message \

--queue-url "<REPLACE_WITH_OUTPUT_FROM_PREVIOUS_COMMAND>" \

--message-body '{"Message": "{\"content\":\"Test message\",\"params\":{\"name\":\"Mario\",\"surname\":\"Rossi\"}}"}'

Initial commit

ab7df8e

julianwood assigned julianwood and marcojahn Feb 12, 2026

mscarimb mentioned this pull request Feb 12, 2026

New pattern submission #2952

Open

marcojahn requested changes Feb 19, 2026

View reviewed changes

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

New serverless pattern - eventbridge-pipes-sqs-to-dynamodb#2950

New serverless pattern - eventbridge-pipes-sqs-to-dynamodb#2950
mscarimb wants to merge 1 commit intoaws-samples:mainfrom
mscarimb:mscarimb-feature-eventbridge-pipes-sqs-to-dynamodb

mscarimb commented Feb 12, 2026

Uh oh!

marcojahn left a comment

Uh oh!

marcojahn Feb 19, 2026

Uh oh!

marcojahn Feb 19, 2026

Uh oh!

marcojahn Feb 19, 2026

Uh oh!

marcojahn Feb 19, 2026

Uh oh!

marcojahn Feb 19, 2026

Uh oh!

marcojahn Feb 19, 2026

Uh oh!

marcojahn Feb 19, 2026

Uh oh!

marcojahn Feb 19, 2026

Uh oh!

marcojahn Feb 19, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

Comments


		class EventbridgePipesSqsToDynamodb(Stack):

		def __init__(self, scope: Construct, construct_id: str, env: cdk.Environment, **kwargs) -> None:

		@@ -0,0 +1,79 @@
		# SQS to DynamoDB using EventBridge Pipes with API Gateway and CDK/Python

	# SQS to DynamoDB using EventBridge Pipes with API Gateway and CDK/Python
	# Amazon SQS to Amazon DynamoDB using Amazon EventBridge Pipes with Amazon API Gateway and CDK/Python

		@@ -0,0 +1,65 @@
		{
		"title": "SQS to DynamoDB using EventBridge Pipes with API Gateway and CDK Python",


		This pattern will send messages from an SQS queue to a DynamoDB table via API Gateway using EventBridge Pipes.

		Learn more about this pattern at Serverless Land Patterns: https://serverlessland.com/patterns/eventbridge-pipes-sqs-to-dynamodb

	When you check the DynamoDB table, you can see the entry with all the attributes parsed by API Gateway.
	Navigate to [AWS Console DynamoDB Tables](https://eu-central-1.console.aws.amazon.com/dynamodbv2/home?#tables) and check for a table with name `Audit-Table`.
	When you check the DynamoDB table, you can see the entry with all the attributes parsed by API Gateway.


		## Testing

		Once this stack is deployed in your AWS account, copy the SQS queue name value from the output.

Conversation

mscarimb commented Feb 12, 2026

Uh oh!

marcojahn left a comment

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

Comments