Работники сельдерея в двух проектах с локальными задачами и взаимной очередью - PullRequest
0 голосов
/ 06 мая 2020

У меня есть два проекта, A и B (в проектах A и B есть рабочий сельдерея). Project A обрабатывает регистрацию пользователей, вход в систему, сброс пароля и т. Д. c. Проект B использует проект A для вещей, связанных с пользователем. Проект B должен хранить некоторые локальные данные о пользователях. Поэтому, когда пользователь в проекте A обновляется, необходимо уведомить проект B (событие в очереди сообщений). Оба проекта используют сельдерей, и у меня есть брокер сообщений, к которому оба проекта подключаются, и они могут читать и записывать в него события. Это работает нормально.

Теперь мне нужно создать задачу в проекте B, которую должен обрабатывать рабочий в проекте B (он же НЕ рабочий в проекте A). Проблема в том, что когда я запускаю задачу в проекте B, она отправляется работнику A, который сообщает, что задача не зарегистрирована (она зарегистрирована в проекте B!).

Я хочу иметь возможность запускать задачи в Project B, которые обрабатываются его работником и не отправляются работнику в проекте A.

...