Использование Celery/Kombu для обработки простых сообщений JSON в Django
В прошлом я использовал приложения Celery async python и Django, где и отправитель, и получатель понимают задачу, отправляемую в RabbitMQ для обработки через Celery (это может быть одно и то же приложение в кластере и т. Д.).
У меня есть пример использования, когда служба.NET публикует сообщения в RabbitMQ в форме JSON, по одному типу сообщений на очередь. Приложение.NET только опубликует сообщение и убедится, что оно было правильно получено Кроликом, а затем уйдет. Затем у меня будет запущено приложение Django, которое ищет сообщения, и поэтому я не уверен, как правильно использовать эти сообщения JSON, чтобы это приложение Django могло просто сохранять данные через свои модели и подтверждать сообщение как обработанное.
Используя Celery/Kombu, я не уверен, что это лучший способ получить доступ к очередям, чтобы у нас был прямой потребитель для каждой очереди. Я понимаю, что Celery использует Kombu под одеялом, поэтому я представляю, что могу создать там потребителя, но потом я предвижу, что невозможно управлять процессом а-ля Celery и Flower, и тогда создание пользователя-мошенника на старте приложения кажется излишним в лучшем случае.