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}) } } 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']})