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

Question

我已经构建了一个应用程序，负责在将传入内容放到主应用程序之前对其进行审核。在有人共享警报后，该警报将落入队列中的sqs。我的应用程序有一个单独的容器，负责执行后台任务，包括检查队列中的新消息。

一旦msg进入系统，它就被存储在发电机db中，并且相应的web套接字消息被发送到前端，通知新的警报已经到达。

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

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

据我所知，我需要在某个数据库中跟踪所有活动用户(选择哪个数据库？)并且能够将输入内容分配给免费的用户。

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

Answer 1

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