From 4580f597b9a922257be8171087cb593007dd29e1 Mon Sep 17 00:00:00 2001 From: Julian Wood Date: Fri, 7 Mar 2025 11:46:22 +0000 Subject: [PATCH 1/4] Fix Python: lambda-function-sqs-report-batch-item-failures --- lambda-function-sqs-report-batch-item-failures/example.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lambda-function-sqs-report-batch-item-failures/example.py b/lambda-function-sqs-report-batch-item-failures/example.py index cdd8c27..f8f3ccc 100644 --- a/lambda-function-sqs-report-batch-item-failures/example.py +++ b/lambda-function-sqs-report-batch-item-failures/example.py @@ -8,7 +8,7 @@ def lambda_handler(event, context): for record in event["Records"]: try: - # process message + print(f"Processed message: {record['body']}") except Exception as e: batch_item_failures.append({"itemIdentifier": record['messageId']}) From c658b8ab46a2a59687fb227f3226df2a350068b7 Mon Sep 17 00:00:00 2001 From: Julian Wood Date: Fri, 7 Mar 2025 15:56:10 +0000 Subject: [PATCH 2/4] Fix Golang: lambda-function-sqs-report-batch-item-failures --- .../example.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/lambda-function-sqs-report-batch-item-failures/example.go b/lambda-function-sqs-report-batch-item-failures/example.go index 2fb9a92..f4e99e5 100644 --- a/lambda-function-sqs-report-batch-item-failures/example.go +++ b/lambda-function-sqs-report-batch-item-failures/example.go @@ -4,7 +4,6 @@ package main import ( "context" - "encoding/json" "fmt" "github.com/aws/aws-lambda-go/events" "github.com/aws/aws-lambda-go/lambda" @@ -14,8 +13,12 @@ func handler(ctx context.Context, sqsEvent events.SQSEvent) (map[string]interfac batchItemFailures := []map[string]interface{}{} for _, message := range sqsEvent.Records { - - if /* Your message processing condition here */ { + if len(message.Body) > 0 { + // Your message processing condition here + fmt.Printf("Successfully processed message: %s\n", message.Body) + } else { + // Message processing failed + fmt.Printf("Failed to process message %s\n", message.Body) batchItemFailures = append(batchItemFailures, map[string]interface{}{"itemIdentifier": message.MessageId}) } } From 097c928f3f239ee97930ae23c2f845c09ff64af0 Mon Sep 17 00:00:00 2001 From: Julian Wood Date: Fri, 7 Mar 2025 16:06:39 +0000 Subject: [PATCH 3/4] Revert "Fix Golang: lambda-function-sqs-report-batch-item-failures" This reverts commit c658b8ab46a2a59687fb227f3226df2a350068b7. --- .../example.go | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/lambda-function-sqs-report-batch-item-failures/example.go b/lambda-function-sqs-report-batch-item-failures/example.go index f4e99e5..2fb9a92 100644 --- a/lambda-function-sqs-report-batch-item-failures/example.go +++ b/lambda-function-sqs-report-batch-item-failures/example.go @@ -4,6 +4,7 @@ package main import ( "context" + "encoding/json" "fmt" "github.com/aws/aws-lambda-go/events" "github.com/aws/aws-lambda-go/lambda" @@ -13,12 +14,8 @@ func handler(ctx context.Context, sqsEvent events.SQSEvent) (map[string]interfac batchItemFailures := []map[string]interface{}{} for _, message := range sqsEvent.Records { - if len(message.Body) > 0 { - // Your message processing condition here - fmt.Printf("Successfully processed message: %s\n", message.Body) - } else { - // Message processing failed - fmt.Printf("Failed to process message %s\n", message.Body) + + if /* Your message processing condition here */ { batchItemFailures = append(batchItemFailures, map[string]interface{}{"itemIdentifier": message.MessageId}) } } From 787a274b006e7e4e458f65ddc01710bdbcbc6b95 Mon Sep 17 00:00:00 2001 From: Julian Wood Date: Fri, 7 Mar 2025 16:10:52 +0000 Subject: [PATCH 4/4] Fix Golang: lambda-function-sqs-report-batch-item-failures --- .../example.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/lambda-function-sqs-report-batch-item-failures/example.go b/lambda-function-sqs-report-batch-item-failures/example.go index 2fb9a92..0346a1c 100644 --- a/lambda-function-sqs-report-batch-item-failures/example.go +++ b/lambda-function-sqs-report-batch-item-failures/example.go @@ -4,7 +4,6 @@ package main import ( "context" - "encoding/json" "fmt" "github.com/aws/aws-lambda-go/events" "github.com/aws/aws-lambda-go/lambda" @@ -14,8 +13,12 @@ func handler(ctx context.Context, sqsEvent events.SQSEvent) (map[string]interfac batchItemFailures := []map[string]interface{}{} for _, message := range sqsEvent.Records { - - if /* Your message processing condition here */ { + if len(message.Body) > 0 { + // Your message processing condition here + fmt.Printf("Successfully processed message: %s\n", message.Body) + } else { + // Message processing failed + fmt.Printf("Failed to process message %s\n", message.MessageId) batchItemFailures = append(batchItemFailures, map[string]interface{}{"itemIdentifier": message.MessageId}) } }