AWS SQS 和 SNS 中的消息结构

Question

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

假设，当p2 从队列中读取时，data 被填充。然后，虽然下面的 sn-p 与 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 写入者，队列中接收到的消息结构似乎有所不同。

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

Answer 1

不是 100% 确定这是否会解决您的所有问题，但作为第一步，至少您可能希望启用“原始消息传递”

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

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