Articles of amazon sqs

我如何让nodejs服务器监听AWS SQS?

在详细解释问题之前,我先告诉你我目前的做法。 我有一个运行setInterval()的js脚本。 和每个间隔,我将调用SQS从队列中获取消息。 如果有消息,我就处理它。 所以,它会无限地运行,直到我杀了这个过程。 我之前也build立了一个节点服务器(使用nodejs.org中的例子) 所以,我想知道的是,而不是定期运行setInterval。 有没有办法,如果SQS中有一条新消息,那么它会触发一个事件并处理消息?

Nodejs sqs队列处理器

我正在尝试编写一个nodejs sqs队列处理器。 "use strict"; var appConf = require('./config/appConf'); var AWS = require('aws-sdk'); AWS.config.loadFromPath('./config/aws_config.json'); var sqs = new AWS.SQS(); var exec = require('child_process').exec; function readMessage() { sqs.receiveMessage({ "QueueUrl": appConf.sqs_distribution_url, "MaxNumberOfMessages": 1, "VisibilityTimeout": 30, "WaitTimeSeconds": 20 }, function (err, data) { var sqs_message_body; if (data.Messages) { if (typeof data.Messages[0] !== 'undefined' && typeof data.Messages[0].Body !== 'undefined') { […]

在使用Amazon SQS完成Lambdafunction时通知浏览器客户端

在我的情况下,我试图实现运行相当耗时的计算的服务器less后端。 这个计算是由Lambdapipe理的,它引用了一些外部的API。 在oder要求这个我使用的Amazon API网关有10秒的执行限制。 但是Lambda运行大约100秒。 为避免这种限制,我使用第二个Lambda函数来执行耗时的计算并报告计算已经开始。 我看起来非常相似: var AWS = require('aws-sdk'); var colors = require('colors'); var functionName = 'really-long' var lambda = new AWS.Lambda({apiVersion: '2015-03-31'}); var params = { FunctionName: functionName, InvocationType: 'Event' }; lambda.invoke(params, function(err, data) { if (err) console.log(err, err.stack); // an error occurred else console.log(functionName.green + " was successfully executed and returned:\n" […]