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