AWS SQS 和 SNS 中的消息结构

Question

我有一个订阅到 SQS 队列 q1 的 SNS 主题 t1。我有一个发布到 t1 的 NodeJS 进程 p1，从 q1 订阅的进程 p2。我还有一个进程 p3 直接写入 q1。

假设，当 p2 从队列中读取时填充 data。然后，虽然以下代码片段使用 p1 作为队列的写入器，但我收到 JSON 解析器错误 p3.

for (var i = 0; i < data.Messages.length; i++) {
 var message = data.Messages[i];
 let messageBody = JSON.parse(message.Body)
 let payload = JSON.parse(messageBody.Message)

我可以处理来自 p3 工作数据的唯一方法是 而不是 有 JSON.parse(messageBody.Message) 并直接处理 messageBody。因此，如果编写器是 SNS 主题订阅或 SQS 编写器，队列中接收到的消息结构似乎是不同的。

你能告诉我是否可以有一个 NodeJS 应用程序来处理来自 SQS 的数据，而不管写入该队列的是什么？

Answer 1

不能 100% 确定这是否会解决您的所有问题，但至少作为第一步，您可能想要启用 'Raw Message Delivery'

https://docs.aws.amazon.com/sns/latest/dg/sns-large-payload-raw-message-delivery.html

这样，SNS 放入队列的消息将不会添加任何额外的属性，因此应该与直接放入的消息相匹配。