Сельдерей настраивает отдельное соединение для производителя и потребителя

У нас есть установка приложения на heroku, которая использует сельдерей для запуска фоновых заданий. Приложение сельдерея использует RabbitMQ в качестве брокера. Мы использовали дополнение RabbitMQ Bigwig от heroku в качестве брокера сообщений AMQP. Это дополнение определяет два отдельных URL-адреса, оптимизированных для производителя и других, оптимизированных для потребителей. Кроме того, согласно документации RabbitMQ рекомендуется использовать отдельные подключения для производителя и потребителя.

Документация по сельдеву не дает возможности указывать соединения отдельно для производителя и потребителя. Есть ли способ указать два разных URL-адреса брокера в сельдерее?

One Solution collect form web for “Сельдерей настраивает отдельное соединение для производителя и потребителя”

К сожалению, нет чистого способа сделать это. Вы можете напрямую task.apply_async пользовательское соединение с брокером на task.apply_async , но это означает отказ от функции пула соединений. Это может сработать для вас.

 from kombu import BrokerConnection conn = BrokerConnection(hostname="producerbroker") mytask.apply_async(args, kwargs, connection=conn) 

Самое простое решение, вероятно, состоит в том, чтобы иметь разные конфигурационные файлы для производителя и рабочего.

Interesting Posts

Доступ к переменной Javascript в шаблоне Django

Эстетика барных прутьев и баров ошибок в морском дне

pyparsing nestedExpr и вложенные круглые скобки

Проблемы с пространством имен Python с параллельным ipython

Python – как пройти проверку подлинности с помощью Google Analytics от AWS Lambda?

Фильтрация списка на основе списка логических элементов

Запуск кода Python, содержащегося в строке

Что означает «следующие пакеты будут заменены каналом с более высоким приоритетом»?

Эффективный способ чтения определенного номера строки файла. (БОНУС: Pizon Manual Misprint)

Импортируйте модуль Python с PyImport_ImportModuleEx для плагина gedit

Соответствующее значение max_packets для функции цикла MQTT

Объединение нескольких временных данных в один массив 2d numpy

Керлинг в Python и вывод в отдельные текстовые файлы

Ошибка создания исполняемого файла с помощью cx_Freeze: IndexError: индекс tuple выходит за пределы диапазона

Низкая производительность чтения на Python

Python - лучший язык программирования в мире.