在AWS SDK for SQS中设置DataType为JSON的问题求助

我来帮你搞定这个SQS消息属性的问题！你遇到的问题其实是对SQS MessageAttributes的数据类型规则理解有点偏差，咱们一步步理清楚：

问题根源 #

• SQS的MessageAttributes只支持三种官方DataType：String、Number、Binary，根本没有Json这个选项，所以你改成"Json"肯定会抛类型错误。
• 当你指定DataType为String时，StringValue必须是字符串类型，直接传JSON对象肯定不符合要求，自然会报错。

正确实现方式 #

如果一定要在MessageAttributes里传递JSON格式的数据，你需要先把JSON对象序列化为字符串，保持DataType为String就可以了，代码示例：

const sqsMessage = {
  MessageAttributes: {
    "data": {
      DataType: "String",
      StringValue: JSON.stringify(payload.data) // 将JSON对象转为字符串
    }
  },
  MessageBody: JSON.stringify(payload),
  QueueUrl: queueUrl
};

当你后续接收这条消息时，只需要把StringValue再解析回JSON对象即可：

// 假设接收到的消息对象为receivedMessage
const parsedData = JSON.parse(receivedMessage.MessageAttributes.data.StringValue);

额外建议 #

其实如果你的payload本身已经包含了所有业务数据，MessageBody已经是序列化后的完整内容了，MessageAttributes更多是用来添加过滤标签、元数据这类辅助信息的。如果不是必须把data放在属性里，直接从MessageBody解析数据也是完全可行的，看你的业务场景来选择就好。

内容的提问来源于stack exchange，提问作者Stas