Невозможно удалить сообщение AWS SQS в GO - PullRequest
Новая
       17

Невозможно удалить сообщение AWS SQS в GO

1 голос
/ 21 июня 2019

Люди,

Я пытаюсь разархивировать сообщение из очереди SQS FIFO и получаю 

cannot unmarshal array into Go struct field SendMessageInput.MessageAttributes of type map[string]*sqs.MessageAttributeValue

// unmarshal for the sqs message
var publishedMessage sqs.SendMessageInput
if err := json.Unmarshal([]byte(*msg.Body), &publishedMessage); err != nil {
  onError(err)
  continue
}

// unmarhsal for the message sent
var result Message
if err := json.Unmarshal([]byte(*publishedMessage.MessageBody), &result); err != nil {
    onError(err)
    continue
}

Само сообщение выглядит нормально, когда я смотрю на сообщение через консоль SQS.

Вот пример сообщения MessageAttributes из сообщения: 

"messageAttributes":[{"name":"foo","dataType":"String","attributeValue":"something"},{"name":"uid","dataType":"String","attributeValue":"26799e9c-9455-11e9-bc42-526af7764f64"}]

Из документации SDK: 

// Each message attribute consists of a Name, Type, and Value. For more information,
    // see Amazon SQS Message Attributes (http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-message-attributes.html)
    // in the Amazon Simple Queue Service Developer Guide.
    MessageAttributes map[string]*MessageAttributeValue `locationName:"MessageAttribute" locationNameKey:"Name" locationNameValue:"Value" type:"map" flattened:"true"`

Что я здесь не так делаю, ребята?

1 Ответ

3 голосов
/ 21 июня 2019

Для тех, кто наткнулся на это ... 

// Message encapsulates all the information to publish in a message
type Message struct {
    Body              json.RawMessage            `json:"body"`
    Headers           map[string]json.RawMessage `json:"headers"`
    Environment       string                     `json:"env"`
    PublishTime       int64                      `json:"publishTime"`
    MessageAttributes []Attributes               `json:"messageAttributes"`
}

for _, msg := range resp.Messages {

  var result Message
  if err := json.Unmarshal([]byte(*msg.Body), &result); err != nil {
    onError(err)
    continue
  }

  metadata := &Metadata{
    ReceiptHandle: *msg.ReceiptHandle,
    MD5OfBody:     *msg.MD5OfBody,
    SQSMessageID:  *msg.MessageId,
    ReceiveCount:  *msg.Attributes[sqs.MessageSystemAttributeNameApproximateReceiveCount],
  }

  onMessage(result, *metadata)

}
...