amazon-sqs

0热度

1回答

botocore.exceptions.ClientError：InvalidClientTokenId

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

-2热度

3回答

这种情况下使用的最佳体系结构是什么？ SQS？ SNS？两者结合？

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

0热度

1回答

从SQS队列中调节读取

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

0热度

1回答

限制SQS上的可用消息数

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

1热度

1回答

Heroku的运行主管

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

0热度

1回答

如何检查AWS DataPipeline中SnsAlarm的状态？

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

0热度

1回答

春云AWS SQS删除策略

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

0热度

1回答

AWS.SQS：我如何从EB工作环境中的messaje获取分支（Node.js）

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

1热度

1回答

AWS消息传递服务是否支持STOMP？

做AWS SNS和SQS支持STOMP protocol？我试着用Google搜索它。我经历了几个论坛，但我还不确定。

1热度

1回答

亚马逊AWS：FIFO SQS，什么被视为交易？

如您所知，Amazon SQS FIFO队列被限制为300 TPS /秒（每秒事务数）。什么被视为交易？一个FIFO的基本用法如下：发送消息读消息删除消息是每一个动作视为交易或只发？或者只发送+读取但不能删除？我在文档中没有发现任何关于它的信息。