Improve SQS logging

logs/logs.go

@@ -266,9 +266,26 @@ func LogApiAudit(fields log.Fields) {
 }
 
 func LogSQSEvent(event events.SQSEvent) {
+	sqsReducedEvents := []map[string]string{}
+
+	for _, record := range event.Records {
+		reducedEvent := map[string]string{
+			"message_id": record.MessageId,
+			"body":       record.Body,
+			"sender":     record.Attributes["SenderId"],
+		}
+
+		for key, attribute := range record.MessageAttributes {
+			if key != "Name" {
+				reducedEvent[key] = *attribute.StringValue
+			}
+		}
+		sqsReducedEvents = append(sqsReducedEvents, reducedEvent)
+	}
+
 	InfoWithFields(map[string]interface{}{
-		"records": event.Records,
-	}, "SQS event start")
+		"records": sqsReducedEvents,
+	}, "")
 }
 
 func SetOutputToFile(file *os.File) {

sqs/sqs.go

@@ -135,7 +135,6 @@ func SendSQSMessage(msgr Messenger, objectToSend interface{}, currentRequestID *
 
 	message := string(jsonBytes)
 	headers := map[string]string{
-		"Name":            "dummy",
 		SQSMessageOnS3Key: "false",
 	}