node.js - AWS SQS 和 SNS 中的消息结构

Question

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

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

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% 确定这是否会解决您的所有问题，但至少作为第一步，您可能想要启用“原始消息传递”

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

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