我正在我的Node.js项目中实现SQS。我的操作是在SQS中发送消息并接收它。 但是当我接收到时,它只是ResponseMetadata对象。
"ResponseMetadata": {
"RequestId": "8659872b-10f0-57b6-9d57-d1852aba1a64"
}
响应中没有消息对象。我该怎么办?我有许多可能性,例如更改参数值等,但没有任何作用。
我的代码
const AWS = require('aws-sdk');
AWS.config.update({ accessKeyId: process.env.AWS_ACCESS_KEY_ID, secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY, region: 'eu-west-1' })
const sqs = new AWS.SQS({apiVersion: '2012-11-05'});
onst queueUrl = "https://eu-west-1.queue.amazonaws.com/******/test-queue";
发送消息
let params = {
MessageBody: 'Hello world!',
MessageAttributes: {
"Title": {
DataType: "String",
StringValue: "The Whistler"
},
"Author": {
DataType: "String",
StringValue: "John Grisham"
},
"WeeksOn": {
DataType: "Number",
StringValue: "6"
}
},
QueueUrl: queueUrl,
DelaySeconds: 0
};
sqs.sendMessage(params, function (err, data) {
if (err) {
res.send(err);
} else {
res.send(data);
}
});
响应是
"ResponseMetadata": {
"RequestId": "da3af650-2642-5460-86b7-a0fe1f9ced6f"
},
"MD5OfMessageBody": "86fb269d190d2c85f6e0468ceca42a20",
"MD5OfMessageAttributes": "1864106991a54cca8b8c732a1841833a",
"MessageId": "13f228b0-7df1-4a9e-bc2b-48535725955e"
接收消息
sqs.getQueueUrl('queue-name', function(err, data) {
if (err) {
console.log("Error", err);
} else {
let params = {
AttributeNames: [
"SentTimestamp"
],
MaxNumberOfMessages: 10,
VisibilityTimeout: 20,
MessageAttributeNames: ["All"],
QueueUrl: data.QueueUrl,
WaitTimeSeconds: 0
};
sqs.receiveMessage(params, function (err, data) {
if (err) {
res.send(err);
} else {
res.send(data);
}
});
}
});
有人能帮忙吗?我是否遗漏了什么?谢谢提前。
receiveMessage
得到的响应吗? - Jason Wadsworth