gpt4 book ai didi

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

转载 作者:行者123 更新时间:2023-12-02 19:01:27 26 4
gpt4 key购买 nike

我有一个订阅到 SQS 队列 q1 的 SNS 主题 t1。我有一个 NodeJS 进程 p1 发布到 t1,进程 p2q1 订阅。我还有一个进程 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/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com