Как спроектировать автоматическое назначение контента из SQS? - PullRequest
1 голос
/ 24 апреля 2019

Я создал приложение, которое отвечает за модерирование входящего контента, прежде чем отправлять его в основное приложение.После того, как кто-то поделился предупреждением, оно попадает в очередь sqs-in-queue.Мое приложение имеет отдельный контейнер, который отвечает за выполнение фоновых задач, включая проверку очередей на наличие новых сообщений.

Как только сообщение MSG входит в систему, оно сохраняется в Dynamo DB, и соответствующее сообщение веб-сокета отправляется на веб-интерфейс., уведомляя о получении нового предупреждения.

Пользователь может войти в систему, назначить предупреждение и модерировать его.Результат будет сохранен в БД, а модерируемый контент будет отправлен в sqs-out.

Я хочу реализовать функцию автоматического назначения.Как модератор, когда я запускаю часы модерации, я должен видеть одно оповещение, которое назначается мне автоматически.Как спроектировать эту функцию?

Как я понимаю, мне нужно отследить всех активных пользователей в какой-то БД (какую БД выбрать?) И иметь возможность назначать входящий контент пользователю, который является бесплатным.

Любые идеи будут высоко оценены.

1 Ответ

1 голос
/ 25 апреля 2019

Хитрость заключается в том, чтобы иметь «назначаемую» очередь работ, которая ставится в очередь после сохранения элемента в динамо.Как и ваша очередь на входящую работу, вам нужна одна из «назначаемых» работ.Клиенты могут запрашивать работу при запуске, приложение будет опрашивать очередь в поисках назначаемой работы.Когда они завершат свою задачу, повторно опросите очередь, чтобы получить следующую доступную задачу.

...