Fix Golang: lambda-function-sqs-report-batch-item-failures

Author: julianwood

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