使用SQS发送json并将其发布

问题描述 投票:2回答:1

我将一个json对象/字符串(都尝试了)放入SQS队列中,并且我试图将其作为有效负载发布到Lambda函数中,该函数在SQS中包含新项时触发。

我的问题是json出现在另一端,并在每个“我拥有的json对象或字符串中添加了额外的\(反斜杠)。

这是我如何在另一端以纯字符串形式添加到SQS的部分json的示例(这是要求:)>

"{\"properties\":{\"colorIconValue\":\"Other\",\"description\":\"According to media reports on Saturday, 26 January, 

虽然文本进入队列时看起来像这样:

{"properties": {"colorIconValue": "Other","description": "International media r

用于将JSON添加到队列的代码来自AWS蓝图:

    console.log("plain text" + incident_report);
                         var params = {
                            MessageBody: incident_report,
                            QueueUrl: QUEUE_URL
                        };
                        //write to SQS
                        sqs.sendMessage(params, function(err,data){
                          if(err) {
                            console.log('error:',"Fail Send Message" + err);
                            context.done('error', "ERROR Put SQS");  // ERROR with message
                          }else{
                            //console.log('data:',data.MessageId);
                            context.done(null,'');  // SUCCESS 
                          }
                        });

我已经尝试将有效负载添加为JSON对象,并将其添加为JSON.stringfy(),但是得到了相同的结果...稍后无法在(http post)上发布。

我正在将json对象/字符串(都尝试过)放入SQS队列中-我试图将其作为有效负载发布到Lambda函数中,该函数在SQS中包含新项时触发。我的问题是...

javascript node.js json string amazon-sqs
1个回答
0
投票

与收到的SQS消息一起使用JSON.parse()。例如:

© www.soinside.com 2019 - 2024. All rights reserved.