我已经构建了一个应用程序，负责在放入主应用程序之前调整传入的内容。有人共享警报后，它会进入队列中的sqs。我的应用程序有一个单独的容器，负责执行后台任务，包括检查新消息的队列。
一旦msg进入系统，它就会存储在dynamo db中，相应的Web套接字消息将被发送到前端，通知新警报已到达。
用户可以登录系统，分配警报并对其进行调节。结果将保存到数据库，经过审核的内容将发送到sqs-out。
我想实现自动分配功能。作为主持人，一旦我开始我的审核时钟，我应该看到一个自动分配给我的警报。如何设计该功能？
据我所知，我需要跟踪某个数据库中的所有活动用户（选择哪个数据库？），并能够将传入的内容分配给免费的用户。
任何想法将受到高度赞赏。
诀窍是让一个“可分配”的工作队列在项目存储在发电机中后入队。就像你的传入工作队列一样，你需要一个“可分配”的工作。客户端在启动时可以要求工作，应用程序将轮询队列，寻找可分配的工作。完成任务后，重新轮询队列以获取下一个可用任务。