В настоящее время я пишу чат-мессенджер, используя GRPC / RabbitMQ для групповых чатов. У меня есть API в Django / DRF, который обрабатывает аутентификацию / журналы сообщений / текстовые сообщения и оповещения по электронной почте и т. Д.
Для этого я хотел бы создать задачу celery, которая подписывается на обмен сообщениями каждой группы, но мне неясноесли есть способ привязать задачу сельдерея к обмену сообщениями.
Реально ли / возможно ли создавать задания сельдерея, которые подписываются на чаты, которые я создаю? Если нет, то как бы вы решили / справились с этими обязанностями?