Как реализовать модель "издатель-подписчик" с помощью rabbitMQ и celery в Django?
Как я знаю, в очереди сообщений есть 2 основные модели, Publish/Subscribe и Producer/Consumer. Producer/Consumer легко реализовать, и основная концепция заключается в том, что какое-то приложение будет отправлять сообщения в мою очередь сообщений, а один из нескольких работников celery будет выбирать сообщение и обрабатывать его. Это может быть сделано путем создания рабочих с помощью celery.
Однако я не понимаю, как именно издатель-подписчик будет работать с RabbitMQ и celery в Django. Как я понимаю, сообщение, произведенное издателем, потребляется всеми подписчиками, которые подписались на определенную очередь. Издатель производит сообщения, а подписчик потребляет их.
Итак, мой вопрос в том, как именно я могу использовать celery workers для подписки на очереди, как именно это будет работать с Django.
Любая теория, блог, документация или видео, которые объясняют то же самое с Django, celery и любой очередью сообщений, помогли бы
Это может помочь