可以使用AWS SDK for JavaScript中提供的方法来轮询SQS消息。以下是示例代码,其中MaxNumberOfMessages设置为1,WaitTimeSeconds设置为30秒:
var AWS = require('aws-sdk');
AWS.config.update({region: 'us-west-2'});
var sqs = new AWS.SQS({apiVersion: '2012-11-05'});
var params = {
QueueUrl: "YOUR_QUEUE_URL",
MaxNumberOfMessages: 1,
WaitTimeSeconds: 30
};
sqs.receiveMessage(params, function(err, data) {
if (err) {
console.log("Receive Error", err);
} else if (data.Messages) {
console.log("Receive Success", data.Messages);
} else {
console.log("No Messages");
}
});
上述代码在SQS队列中轮询消息,每30秒尝试获取1条消息。您可以调整WaitTimeSeconds以增加或减少轮询间隔时间。