我有一个订阅到 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 的数据,而不管队列中写入了什么?
最佳答案
不能 100% 确定这是否会解决您的所有问题,但至少作为第一步,您可能想要启用“原始消息传递”
https://docs.aws.amazon.com/sns/latest/dg/sns-large-payload-raw-message-delivery.html
这样,SNS 放入队列的消息不会添加任何额外的属性,因此应该与直接放入的消息相匹配。
关于node.js - AWS SQS 和 SNS 中的消息结构,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/65524656/