Использование Pika с Django (основанный на событиях микросервис с использованием django rest framework)
Кто-нибудь здесь имеет опыт реализации Пика с Джанго? Я в основном управляю основанным на событиях микросервисом, используя django rest framework. И используя RabbitMQ в качестве шины сообщений. Я знаю, что библиотека по умолчанию для использования в этом случае будет Celery, но я ищу более легкую версию, где я мог бы просто реализовать простой паб / саб в сообщениях.
Кто-нибудь реализовывал такой сервис с помощью pika раньше? Мой вопрос - как вы создаете пика как отдельный процесс вместе с Django? Или есть более элегантное решение?
Заранее спасибо.
--- ОБНОВИТЬ ---
В итоге мы сделали:
Для издателя:
- Мы создаем отдельный поток (или много, если вам нужно опубликовать большой объем / сек), который поддерживает соединение pika.
Для подписчика:
- Мы порождаем отдельный рабочий процесс (в отдельном контейнере), который имеет контекст django (используя django.setup()), который принимает сообщения от RabbitMQ