amazon-sqs

    3热度

    2回答

    我正在使用python Boto3代码,当一个实例从Auto Scaling组中终止时,它会通知发布消息到SQS的SNS。当通知SNS时,也会触发Lambda,它会执行boto脚本以从SQS获取消息。 我使用的参考码是Sending and Receiving Messages in Amazon SQS。 这里是代码片段: if messages.get('Messages'): m

    1热度

    1回答

    我一直在努力从AWS队列中收到一条消息,以便删除邮件。 我使用的功能是: <cffunction name="deleteMessage" output="true" returntype="void"> <cfargument name="uri" type="string" required="true"> <cfargument name="messageId" type

    0热度

    1回答

    我通过设在这里快速入门走了。我安装了AWS CLI https://boto3.readthedocs.io/en/latest/guide/quickstart.html ,并与本人的有效配置钥匙它。我已经在〜/ .aws/credentials和〜/ .aws/config中加入了检查和〜/ .aws/config。在这一点上我应该可以在命令提示符下运行我的py脚本python bin/pro

    -2热度

    3回答

    我在AWS内部的EC2实例上有一个中央C#窗口服务。它的任务是创建任务(JSON内部的指令),然后将这些任务发送到运行在AWS以外的服务器上的各个Windows服务(例如,在每个商店中有一个服务器的灰浆零售店)。 这些单独的服务器根据JSON任务执行一些处理,然后将消息发送回AWS内的中央窗口服务。此设计目前正在使用AWS SQS。 我最初的设计是使用1个SQS队列消息到外部服务器,1个SQS队列

    0热度

    1回答

    我有一个读取SQS队列的Mule应用程序。我正试图找到一种方法来限制我从队列中读取数据。 我的要求是限制轮询之间的时间,也一次只读取一条消息。 调查队列如果设置在骡子SQS以下每10秒只有1个新的消息 :将对应于我后收到的消息连接器? pollingPeriod numberOfMessages 我有点不确定从阅读documenation pollingPeriod是否是SQS长轮询,这不是我想要

    0热度

    1回答

    根据文档(AWS SQS Limits),每个队列(在标准队列中)的最大飞行消息数为120,000。 但SQS是否对队列中的可用消息有任何限制? 我猜想队列在SQS中可以保留的消息数量没有限制,但我还没有在文档上找到任何明确的声明。

    1热度

    1回答

    我想知道是否有人知道如何在Heroku上运行Supervisor来管理队列工?我设法为我的Laravel应用程序在本地运行Supervisor,但不知道如何创建更多工作进程以更快地完成作业队列。 我问Heroku在这方面的支持,他们说它应该可以工作,但他们没有任何文档,我也不认为他们会帮我解决这个问题。目前,让更多工作人员进入队列(我使用SQS)的唯一方法是通过Procfile创建更多进程,您必须

    0热度

    1回答

    我配置了一个执行SQL语句并将数据转储到S3存储桶的数据管道。管道中的一切工作正常。数据正在成功转储。今天,我在Activity上的OnSuccess事件中添加了一个SNSAlarm,并为该SNS主题订阅了一个SQS队列。但是,即使活动成功,我也不会在队列中收到任何消息,也不会看到任何与SNS成功或失败相关的日志。 有没有人在AWS Datapipeline中使用过SnsAlarm?任何帮助都会很

    0热度

    1回答

    我们有SQS监听器,如: @MessageMapping("queueName") void listen(String message) { ... } 此队列关联的死信队列配置重驱动的策略。 问题是默认的Spring Cloud AWS实现在轮询它时发送消息并在内部进行连线3处理它的重试,然后失败。 我可以看到有一个SqsMessageDeletionPolicy枚举ALWAYS和ON_

    0热度

    1回答

    我创建了一个示例应用程序,用于从AWS SQS队列中读取消息。如果重要的话,但是我怀疑。 我设法得到消息的正文并将其写入数据库,但我没有看到其他信息(如属性)在哪里? 在一个连接到队列的工作环境中,当创建一条新消息时,应用程序通过POST被调用,所以我使用req.on('data', function (chunk){...}。 'chunk'包含主体字符串(实际上是Buffer)。 如何找到自定