AWS两个SQS队列发送到一个工作者
共有1个答案
最好在消息中引入一个属性类型。消息类型可以是email/fileupload。根据属性类型，工作人员可以使用消息调用相应的服务。
使用上述方法，您将能够使用一个工作者&一个队列来处理消息。您还可以自动缩放服务器，并且使用多个工作人员处理消息不会出现问题。
-
我有一个IAM用户的策略，该策略是为从特定SQS队列发送和接收消息而创建的。当使用AWS CLI并发出命令时，会出现错误： 我认为应该只返回IAM用户被授予该操作的队列，这是不是错了？ 欢迎任何指导/建议！谢了！
-
我有50KAWS Lambda实例同时运行，它们都向SQS FIFO队列发送消息。 我想知道每秒可以发送到SQS FIFO队列的最大消息数是多少？ 我在AWS文档中找不到这样的信息。
-
我将AWSSDK用于Java，其中我将数据从AWS Lambda发送到SQS。 我们遇到异常： 代码： 背景我们正在尝试做什么： 我们有一个主Lambda函数，用于创建和初始化SQS队列，并包含应该处理的每个记录的详细信息。现在，SQS队列需要设置为从队列中创建X个消息的批，并为每个批自动调用另一个SQS Lambda函数。
-
我目前正在尝试使用RabbitMQ（具有出色的RabbitMQBundle）来处理大量的异步工作。 目标是让一个队列发布相同类型的消息，并让多个服务器上的X个工作者在同一时间内查看消息。 每个工人都要偷看一条消息，完成工作，然后偷看另一条消息，等等。 这里是我的conf： 在我的consumer中，我有一个日志文件中的条目和120秒的睡眠。 我启动了php app/console rabbitmq
-
我正在尝试设计一个基于SQS、Lambda和SNS的小型消息处理系统。在失败的情况下，我希望将消息排入死信队列(DLQ)中，并调用webhook。 目前，如果一切顺利，流程应该是这样的： SQS（用于处理重试）将消息排入队列 lambda由SQS调用并处理消息 lambda发送webhook，并正常完成 如果lambda中的某些东西出错（无法调用success webhook，无法处理手头的任务）
-
我试图实现一个AWS SQS队列，以最大限度地减少来自后端服务器的数据库交互，但我遇到了问题。 我有一个消费者进程，它从一个SQS队列中查找消息 为了测试功能，我为一个客户端实现了逻辑。它运行得很好。然而，当我添加了3个客户端时，它不能正常工作。我能够看到SQS队列被500条消息卡住了，后端作业正在正常工作，从队列中读取。 我需要增加后端作业的数量还是增加客户端SQS队列的数量？现在，所有客户端都