diff --git a/fifo-sqs-redrive/README.md b/fifo-sqs-redrive/README.md
new file mode 100644
index 000000000..ba74b5636
--- /dev/null
+++ b/fifo-sqs-redrive/README.md
@@ -0,0 +1,108 @@
+# Redrive SQS FIFO Queue messages from DLQ
+
+The pattern shows the redrive capability of Amazon SQS FIFO queues from a dead letter queue. The SAM template deploys two Amazon SQS FIO queues with DLQ, and two AWS Lambda functions to simulate the redrive capability of SQS.
+
+Learn more about this pattern at Serverless Land Patterns:https://serverlessland.com/patterns/fifio-sqs-redrive
+
+Important: this application uses various AWS services and there are costs associated with these services after the Free Tier usage - please see the [AWS Pricing page](https://aws.amazon.com/pricing/) for details. You are responsible for any AWS costs incurred. No warranty is implied in this example.
+
+## Requirements
+
+- [Create an AWS account](https://portal.aws.amazon.com/gp/aws/developer/registration/index.html) if you do not already have one and log in. The IAM user that you use must have sufficient permissions to make necessary AWS service calls and manage AWS resources.
+- [AWS CLI](https://docs.aws.amazon.com/cli/latest/userguide/install-cliv2.html) installed and configured
+- [Git Installed](https://git-scm.com/book/en/v2/Getting-Started-Installing-Git)
+- [AWS Serverless Application Model](https://docs.aws.amazon.com/serverless-application-model/latest/developerguide/serverless-sam-cli-install.html) (AWS SAM) installed
+
+## Deployment Instructions
+
+1. Create a new directory, navigate to that directory in a terminal and clone the GitHub repository:
+ ```
+ git clone https://github.com/aws-samples/serverless-patterns
+ ```
+2. Change directory to the pattern directory:
+ ```
+ cd fifo-sqs-redrive
+ ```
+3. From the command line, use AWS SAM to deploy the AWS resources for the pattern as specified in the template.yml file:
+ ```
+ sam deploy --guided
+ ```
+4. During the prompts:
+ * Enter a stack name
+ * Enter `us-east-1` or any other supported AWS Region.
+ * Allow SAM CLI to create IAM roles with the required permissions. Please keep all other options to default.
+5. Make a note of the output, which will be used during testing.
+
+## How it works
+
+* This template creates two Amazon SQS queues - `MyOriginalQueue.fifo` and `MyReProcessQueue.fifo` along with DLQ `MyDeadLetterQueue.fifo`.
+* The template also creates two AWS Lambda functions `MyOriginalQueueFunction` and `ReProcessQueueFunction` to poll messages from `MyOriginalQueue.fifo` and `MyReProcessQueue.fifo` respectively through event source mapping.
+* The Lambda function `MyOriginalQueueFunction` raises exception to simulate message processing failure. Hence the message moves to DLQ `MyDeadLetterQueue.fifo` once the retry is exhausted.
+* We then redrive the message from DLQ `MyDeadLetterQueue.fifo` to `MyReProcessQueue.fifo` using AWS CLI command.
+* Message is successfully processed by `ReProcessQueueFunction` Lambda function.
+
+
+Please refer to the architecture diagram below:
+
+
+
+## Testing
+
+1. Run the below aws cli command to push a JSON message into `MyOriginalQueue.fifo`. Please replace `{MyOriginalQueueUrl}` with the value received from the `sam deploy` command output and also replace `{your-region}` with your deployment region.
+ ```bash
+ aws sqs send-message --queue-url {MyOriginalQueueUrl} --message-body '{"id":123,"name":"John","data":{"age":30,"job":"Developer"}}' --message-group-id "group1" --region {your-region}
+ ```
+
+ Sample output:
+ ```bash
+ {
+ "MD5OfMessageBody": "2a33xxxxxxxxxxxxxd34a",
+ "MessageId": "3809xxx-xxxx-xxxx-xxxx-exxxxb88b279",
+ "SequenceNumber": "18883xxxxxxx616"
+ }
+ ```
+2. Now, open [AWS SQS Console](https://console.aws.amazon.com/sqs), select your deployment region and validate the number of messages in `MyOriginalQueue.fifo`, `MyReProcessQueue.fifo` and `MyDeadLetterQueue.fifo` queues. You may have to refresh a few times while the message is being processed by `MyOriginalQueueFunction` AWS Lambda function. The message should be in the DLQ. PLease refer to the diagram below:
+ 
+
+
+
+
+3. Also, validate from the Amazon CloudWatch log of `MyOriginalQueueFunction` that it failed to process the message due to an exception.
+ 
+
+
+
+4. Now, let us redrive the message from `MyDeadLetterQueue.fifo` to `MyReProcessQueue.fifo` using the below aws cli command. Please replace `{MyOriginalQueueUrl}` and `{MyReProcessQueueArn}` with the value received from the `sam deploy` command output and also replace `{your-region}` with your deployment region.
+ ```bash
+ aws sqs start-message-move-task --source-arn {MyDeadLetterQueueArn} --destination-arn {MyReProcessQueueArn} --region {your-region}
+ ```
+
+ Sample output:
+ ```bash
+ {
+ "TaskHandle": "eyJ0YXxxxxxxxxxxxxxxxxm8ifQ=="
+ }
+ ```
+
+
+5. Again, let us validate the number of messages in `MyOriginalQueue.fifo`, `MyReProcessQueue.fifo` and `MyDeadLetterQueue.fifo` queues from [AWS SQS Console](https://console.aws.amazon.com/sqs). You may have to refresh a few times while the message is being processed by `ReProcessQueueFunction` AWS Lambda function. There should not be any messages in any of the queues now as the message got successfully reprocessed now. PLease refer to the diagram below:
+ 
+
+
+
+6. Also, validate from the Amazon CloudWatch log of `ReProcessQueueFunction` that it processed the message successfully.
+ 
+
+
+## Cleanup
+
+
+1. Delete the stack
+ ```bash
+ sam delete
+ ```
+
+----
+Copyright 2024 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+
+SPDX-License-Identifier: MIT-0
diff --git a/fifo-sqs-redrive/example-pattern.json b/fifo-sqs-redrive/example-pattern.json
new file mode 100644
index 000000000..f08280a2e
--- /dev/null
+++ b/fifo-sqs-redrive/example-pattern.json
@@ -0,0 +1,60 @@
+{
+ "title": "Redrive SQS FIFO Queue messages from DLQ",
+ "description": "The SAM template deploys Amazon SQS FIFO queues with DLQ and AWS Lambda functions to simulate the redrive capability of SQS FIFO queues from DLQ.",
+ "language": "Python",
+ "level": "200",
+ "framework": "SAM",
+ "introBox": {
+ "headline": "How it works",
+ "text": [
+ "This template creates two Amazon SQS queues - MyOriginalQueue.fifo and MyReProcessQueue.fifo along with DLQ MyDeadLetterQueue.fifo.",
+ "The template also creates two AWS Lambda functions MyOriginalQueueFunction and ReProcessQueueFunction to poll messages from MyOriginalQueue.fifo and MyReProcessQueue.fifo respectively through event source mapping.",
+ "The Lambda function MyOriginalQueueFunction raises exception to simulate message processing failure. Hence the message moves to DLQ MyDeadLetterQueue.fifo once the retry is exhausted.",
+ "We then redrive the message from DLQ MyDeadLetterQueue.fifo to MyReProcessQueue.fifo using AWS CLI command.",
+ "Message is successfully processed by ReProcessQueueFunction Lambda function."
+ ]
+ },
+ "gitHub": {
+ "template": {
+ "repoURL": "https://github.com/aws-samples/serverless-patterns/tree/main/fifo-sqs-redrive",
+ "templateURL": "serverless-patterns/fifo-sqs-redrive",
+ "projectFolder": "fifo-sqs-redrive",
+ "templateFile": "template.yaml"
+ }
+ },
+ "resources": {
+ "bullets": [
+ {
+ "text": "Moving messages out of a dead-letter queue",
+ "link": "https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-dead-letter-queues.html#sqs-dead-letter-queues-redrive"
+ },
+ {
+ "text": "AWS CLI Command to start message redrive",
+ "link": "https://awscli.amazonaws.com/v2/documentation/api/latest/reference/sqs/start-message-move-task.html"
+ }
+ ]
+ },
+ "deploy": {
+ "text": [
+ "sam deploy --guided"
+ ]
+ },
+ "testing": {
+ "text": [
+ "See the GitHub repo for detailed testing instructions."
+ ]
+ },
+ "cleanup": {
+ "text": [
+ "Delete the stack: sam delete."
+ ]
+ },
+ "authors": [
+ {
+ "name": "Biswanath Mukherjee",
+ "image": "https://d1rwvjey2iif32.cloudfront.net",
+ "bio": "I am a Sr. Solutions Architect working at AWS India.",
+ "linkedin": "biswanathmukherjee"
+ }
+ ]
+}
diff --git a/fifo-sqs-redrive/fifo-sqs-redrive.json b/fifo-sqs-redrive/fifo-sqs-redrive.json
new file mode 100644
index 000000000..aa9c30b9b
--- /dev/null
+++ b/fifo-sqs-redrive/fifo-sqs-redrive.json
@@ -0,0 +1,84 @@
+{
+ "title": "Redrive SQS FIFO Queue messages from DLQ",
+ "description": "The SAM template deploys Amazon SQS FIFO queues with DLQ and AWS Lambda functions to simulate the redrive capability of SQS FIFO queues from DLQ.",
+ "language": "Python",
+ "level": "200",
+ "framework": "SAM",
+ "introBox": {
+ "headline": "How it works",
+ "text": [
+ "This template creates two Amazon SQS queues - MyOriginalQueue.fifo and MyReProcessQueue.fifo along with DLQ MyDeadLetterQueue.fifo.",
+ "The template also creates two AWS Lambda functions MyOriginalQueueFunction and ReProcessQueueFunction to poll messages from MyOriginalQueue.fifo and MyReProcessQueue.fifo respectively through event source mapping.",
+ "The Lambda function MyOriginalQueueFunction raises exception to simulate message processing failure. Hence the message moves to DLQ MyDeadLetterQueue.fifo once the retry is exhausted.",
+ "We then redrive the message from DLQ MyDeadLetterQueue.fifo to MyReProcessQueue.fifo using AWS CLI command.",
+ "Message is successfully processed by ReProcessQueueFunction Lambda function."
+ ]
+ },
+ "gitHub": {
+ "template": {
+ "repoURL": "https://github.com/aws-samples/serverless-patterns/tree/main/fifo-sqs-redrive",
+ "templateURL": "serverless-patterns/fifo-sqs-redrive",
+ "projectFolder": "fifo-sqs-redrive",
+ "templateFile": "template.yaml"
+ }
+ },
+ "resources": {
+ "bullets": [
+ {
+ "text": "Moving messages out of a dead-letter queue",
+ "link": "https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-dead-letter-queues.html#sqs-dead-letter-queues-redrive"
+ },
+ {
+ "text": "AWS CLI Command to start message redrive",
+ "link": "https://awscli.amazonaws.com/v2/documentation/api/latest/reference/sqs/start-message-move-task.html"
+ }
+ ]
+ },
+ "deploy": {
+ "text": [
+ "sam deploy --guided"
+ ]
+ },
+ "testing": {
+ "text": [
+ "See the GitHub repo for detailed testing instructions."
+ ]
+ },
+ "cleanup": {
+ "text": [
+ "Delete the stack: sam delete."
+ ]
+ },
+ "authors": [
+ {
+ "name": "Biswanath Mukherjee",
+ "image": "https://d1rwvjey2iif32.cloudfront.net",
+ "bio": "I am a Sr. Solutions Architect working at AWS India.",
+ "linkedin": "biswanathmukherjee"
+ }
+ ],
+ "patternArch": {
+ "icon1": {
+ "x": 20,
+ "y": 30,
+ "service": "sqs",
+ "label": "Amazon SQS"
+ },
+ "icon2": {
+ "x": 50,
+ "y": 30,
+ "service": "lambda",
+ "label": "AWS Lambda"
+ },
+ "icon3": {
+ "x": 20,
+ "y": 70,
+ "service": "sqs",
+ "label": "Amazon SQS (DLQ)"
+ },
+ "line1": {
+ "from": "icon1",
+ "to": "icon2"
+ }
+ }
+}
diff --git a/fifo-sqs-redrive/fifo-sqs-redrive/fifo-sqs-redrive.json b/fifo-sqs-redrive/fifo-sqs-redrive/fifo-sqs-redrive.json
new file mode 100644
index 000000000..aa9c30b9b
--- /dev/null
+++ b/fifo-sqs-redrive/fifo-sqs-redrive/fifo-sqs-redrive.json
@@ -0,0 +1,84 @@
+{
+ "title": "Redrive SQS FIFO Queue messages from DLQ",
+ "description": "The SAM template deploys Amazon SQS FIFO queues with DLQ and AWS Lambda functions to simulate the redrive capability of SQS FIFO queues from DLQ.",
+ "language": "Python",
+ "level": "200",
+ "framework": "SAM",
+ "introBox": {
+ "headline": "How it works",
+ "text": [
+ "This template creates two Amazon SQS queues - MyOriginalQueue.fifo and MyReProcessQueue.fifo along with DLQ MyDeadLetterQueue.fifo.",
+ "The template also creates two AWS Lambda functions MyOriginalQueueFunction and ReProcessQueueFunction to poll messages from MyOriginalQueue.fifo and MyReProcessQueue.fifo respectively through event source mapping.",
+ "The Lambda function MyOriginalQueueFunction raises exception to simulate message processing failure. Hence the message moves to DLQ MyDeadLetterQueue.fifo once the retry is exhausted.",
+ "We then redrive the message from DLQ MyDeadLetterQueue.fifo to MyReProcessQueue.fifo using AWS CLI command.",
+ "Message is successfully processed by ReProcessQueueFunction Lambda function."
+ ]
+ },
+ "gitHub": {
+ "template": {
+ "repoURL": "https://github.com/aws-samples/serverless-patterns/tree/main/fifo-sqs-redrive",
+ "templateURL": "serverless-patterns/fifo-sqs-redrive",
+ "projectFolder": "fifo-sqs-redrive",
+ "templateFile": "template.yaml"
+ }
+ },
+ "resources": {
+ "bullets": [
+ {
+ "text": "Moving messages out of a dead-letter queue",
+ "link": "https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-dead-letter-queues.html#sqs-dead-letter-queues-redrive"
+ },
+ {
+ "text": "AWS CLI Command to start message redrive",
+ "link": "https://awscli.amazonaws.com/v2/documentation/api/latest/reference/sqs/start-message-move-task.html"
+ }
+ ]
+ },
+ "deploy": {
+ "text": [
+ "sam deploy --guided"
+ ]
+ },
+ "testing": {
+ "text": [
+ "See the GitHub repo for detailed testing instructions."
+ ]
+ },
+ "cleanup": {
+ "text": [
+ "Delete the stack: sam delete."
+ ]
+ },
+ "authors": [
+ {
+ "name": "Biswanath Mukherjee",
+ "image": "https://d1rwvjey2iif32.cloudfront.net",
+ "bio": "I am a Sr. Solutions Architect working at AWS India.",
+ "linkedin": "biswanathmukherjee"
+ }
+ ],
+ "patternArch": {
+ "icon1": {
+ "x": 20,
+ "y": 30,
+ "service": "sqs",
+ "label": "Amazon SQS"
+ },
+ "icon2": {
+ "x": 50,
+ "y": 30,
+ "service": "lambda",
+ "label": "AWS Lambda"
+ },
+ "icon3": {
+ "x": 20,
+ "y": 70,
+ "service": "sqs",
+ "label": "Amazon SQS (DLQ)"
+ },
+ "line1": {
+ "from": "icon1",
+ "to": "icon2"
+ }
+ }
+}
diff --git a/fifo-sqs-redrive/image/all-msg-processed.png b/fifo-sqs-redrive/image/all-msg-processed.png
new file mode 100644
index 000000000..f5318cb87
Binary files /dev/null and b/fifo-sqs-redrive/image/all-msg-processed.png differ
diff --git a/fifo-sqs-redrive/image/architecture.png b/fifo-sqs-redrive/image/architecture.png
new file mode 100644
index 000000000..6c99664e6
Binary files /dev/null and b/fifo-sqs-redrive/image/architecture.png differ
diff --git a/fifo-sqs-redrive/image/lambda-processing-error.png b/fifo-sqs-redrive/image/lambda-processing-error.png
new file mode 100644
index 000000000..77e365f2b
Binary files /dev/null and b/fifo-sqs-redrive/image/lambda-processing-error.png differ
diff --git a/fifo-sqs-redrive/image/lambda-reprocessed-msg.png b/fifo-sqs-redrive/image/lambda-reprocessed-msg.png
new file mode 100644
index 000000000..f5bff8406
Binary files /dev/null and b/fifo-sqs-redrive/image/lambda-reprocessed-msg.png differ
diff --git a/fifo-sqs-redrive/image/msg-in-dlq.png b/fifo-sqs-redrive/image/msg-in-dlq.png
new file mode 100644
index 000000000..6aa285fe2
Binary files /dev/null and b/fifo-sqs-redrive/image/msg-in-dlq.png differ
diff --git a/fifo-sqs-redrive/originalmessage/app.py b/fifo-sqs-redrive/originalmessage/app.py
new file mode 100644
index 000000000..6fb61ef52
--- /dev/null
+++ b/fifo-sqs-redrive/originalmessage/app.py
@@ -0,0 +1,14 @@
+import json
+import boto3
+import os
+
+sqs = boto3.client('sqs')
+
+def lambda_handler(event, context):
+
+ for record in event['Records']:
+ message = json.loads(record['body'])
+ print(message)
+ raise Exception('Failed to process message')
+
+
\ No newline at end of file
diff --git a/fifo-sqs-redrive/redrivenmessage/app.py b/fifo-sqs-redrive/redrivenmessage/app.py
new file mode 100644
index 000000000..afe56dac3
--- /dev/null
+++ b/fifo-sqs-redrive/redrivenmessage/app.py
@@ -0,0 +1,18 @@
+import json
+import boto3
+import os
+
+sqs = boto3.client('sqs')
+
+def lambda_handler(event, context):
+
+ for record in event['Records']:
+ message = json.loads(record['body'])
+
+ print("Message redriven from DLQ")
+ print(f"Processed message: {message}")
+ # Delete message if processed successfully
+ sqs.delete_message(
+ QueueUrl=os.environ['QUEUE_URL'],
+ ReceiptHandle=record['receiptHandle']
+ )
diff --git a/fifo-sqs-redrive/template.yaml b/fifo-sqs-redrive/template.yaml
new file mode 100644
index 000000000..42904b218
--- /dev/null
+++ b/fifo-sqs-redrive/template.yaml
@@ -0,0 +1,92 @@
+AWSTemplateFormatVersion: '2010-09-09'
+Transform: AWS::Serverless-2016-10-31
+Description: SQS with DLQ and Lambda event source
+
+Resources:
+ ## Define the SQS Queues ##
+ MyOriginalQueue:
+ Type: AWS::SQS::Queue
+ Properties:
+ QueueName: MyOriginalQueue.fifo
+ FifoQueue: true
+ ContentBasedDeduplication: true
+ VisibilityTimeout: 30
+ MessageRetentionPeriod: 1209600
+ RedrivePolicy:
+ deadLetterTargetArn: !GetAtt MyDeadLetterQueue.Arn
+ maxReceiveCount: 1
+
+ MyDeadLetterQueue:
+ Type: AWS::SQS::Queue
+ Properties:
+ QueueName: MyDeadLetterQueue.fifo
+ FifoQueue: true
+ ContentBasedDeduplication: true
+ MessageRetentionPeriod: 1209600
+ RedriveAllowPolicy:
+ redrivePermission: "allowAll"
+
+ MyReProcessQueue:
+ Type: AWS::SQS::Queue
+ Properties:
+ QueueName: MyReProcessQueue.fifo
+ FifoQueue: true
+ ContentBasedDeduplication: true
+ VisibilityTimeout: 30
+ MessageRetentionPeriod: 1209600
+ RedrivePolicy:
+ deadLetterTargetArn: !GetAtt MyDeadLetterQueue.Arn
+ maxReceiveCount: 1
+
+
+ ## Define the Lambda Functions ##
+ MyOriginalQueueFunction:
+ Type: AWS::Serverless::Function
+ Properties:
+ CodeUri: originalmessage/
+ Handler: app.lambda_handler
+ Runtime: python3.12
+ FunctionName: MyOriginalQueueFunction
+ Policies:
+ - SQSPollerPolicy:
+ QueueName: !GetAtt MyOriginalQueue.QueueName
+ Environment:
+ Variables:
+ QUEUE_URL: !Ref MyOriginalQueue
+ Events:
+ SqsEvent:
+ Type: SQS
+ Properties:
+ Queue: !GetAtt MyOriginalQueue.Arn
+ BatchSize: 10
+
+ ReProcessQueueFunction:
+ Type: AWS::Serverless::Function
+ Properties:
+ CodeUri: redrivenmessage/
+ Handler: app.lambda_handler
+ Runtime: python3.12
+ FunctionName: ReProcessQueueFunction
+ Policies:
+ - SQSPollerPolicy:
+ QueueName: !GetAtt MyReProcessQueue.QueueName
+ Environment:
+ Variables:
+ QUEUE_URL: !Ref MyReProcessQueue
+ Events:
+ SqsEvent:
+ Type: SQS
+ Properties:
+ Queue: !GetAtt MyReProcessQueue.Arn
+ BatchSize: 10
+
+Outputs:
+ MyOriginalQueueUrl:
+ Description: "MyOriginalQueue URL"
+ Value: !Ref MyOriginalQueue
+ MyDeadLetterQueueArn:
+ Description: "MyDeadLetterQueue ARN"
+ Value: !GetAtt MyDeadLetterQueue.Arn
+ MyReProcessQueueArn:
+ Description: "MyReProcessQueue ARN"
+ Value: !GetAtt MyReProcessQueue.Arn
\ No newline at end of file