小编Bar*_*yon的帖子

带有 aws-sdk receiveMessage Stall 的 Amazon SQS

我将 aws-sdk 节点模块与(据我所知)批准的消息轮询方式一起使用。

这基本上总结为:

        sqs.receiveMessage({
            QueueUrl: queueUrl,
            MaxNumberOfMessages: 10,
            WaitTimeSeconds: 20
        }, function(err, data) {
            if (err) {
                logger.fatal('Error on Message Recieve');
                logger.fatal(err);
            } else {
                // all good
                if (undefined === data.Messages) {
                    logger.info('No Messages Object');
                } else if (data.Messages.length > 0) {
                    logger.info('Messages Count: ' + data.Messages.length);

                    var delete_batch = new Array();
                    for (var x=0;x<data.Messages.length;x++) {
                        // process
                        receiveMessage(data.Messages[x]);

                        // flag to delete

                        var pck = new Array();
                        pck['Id'] = data.Messages[x].MessageId;
                        pck['ReceiptHandle'] = data.Messages[x].ReceiptHandle;

                        delete_batch.push(pck);
                    }

                    if (delete_batch.length …
Run Code Online (Sandbox Code Playgroud)

amazon-sqs amazon-web-services node.js

6
推荐指数
1
解决办法
2694
查看次数

标签 统计

amazon-sqs ×1

amazon-web-services ×1

node.js ×1