Производитель комбу и потребитель сельдерея
Может ли производитель комбу поставить в очередь сообщение на rabbitmq для обработки сельдереями? Похоже, что работники сельдерея не понимают послания производителя комбу.
3 ответа
Я понимаю, что для связи с RabbitMQ вам потребуется любая библиотека, соответствующая спецификации AMQP. Kombu - одна из таких библиотек, которая может связываться с биржей RabbitMQ, прослушивать и обрабатывать сообщения, порождая многочисленных потребителей. Celery - это не что иное, как генератор асинхронных задач, который имеет множество надстроек, таких как обработка в памяти, возможность записи в кэш DB/Redis, выполнение сложных операций и так далее. Сказал, что теперь вы можете использовать комбу для чтения и записи сообщений в / из RMQ и использовать работников сельдерея для обработки сообщения.
Я знаю, что уже поздно отвечать, но если кому-то это нужно, то это так.
Может быть, это может помочь. Я столкнулся с такой проблемой, и я нашел ответ сам.
Сотруднику Celery для обработки сообщения требуется дополнительная информация. Имя задачи, идентификатор в заголовках и т. д.