如何设计来自 SQS 的自动分配内容？

Question

我已经构建了一个应用程序，该应用程序负责在进入主应用程序之前调节传入的内容。在有人分享了一个警报后，它就会落入 sqs-in-queue。我的应用有一个单独的容器，负责执行后台任务，包括检查队列中的新消息。

一旦 msg 进入系统，它就会存储在 dynamo db 中，并将相应的 web socket 消息发送到前端，通知新警报到达。

用户可以登录系统，分配警报并对其进行审核。 结果将保存到数据库，审核后的内容将发送到 sqs-out。

我想实现自动分配功能。作为主持人，一旦我启动了我的审核时钟，我应该会看到一个自动分配给我的警报。如何设计该功能？

据我了解，我需要跟踪某个数据库中的所有活动用户（选择哪个数据库？），并能够将传入内容分配给免费的用户。

任何想法都将受到高度赞赏。

Answer 1

诀窍是有一个“可分配”的工作队列，在项目存储在发电机中后排队。就像您的传入工作队列一样，您需要一项“可分配”的工作。客户可以在启动时要求工作，应用程序将轮询队列，寻找可分配的工作。当他们完成任务后，重新轮询队列以获取下一个可用任务。