diff --git a/logs/logs.go b/logs/logs.go index de3505436269f37181a43c92e8b9ce8a3e6a952f..ca8d401d0dba3f76b06feef3056f14b26b4711bb 100644 --- a/logs/logs.go +++ b/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) { diff --git a/sqs/sqs.go b/sqs/sqs.go index 67ead6c56413a1755985c2da62d78cd548d494a3..cf452f77eb080211a46efb69f9983e2b1bc7a933 100644 --- a/sqs/sqs.go +++ b/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", }