Как я могу заставить сельдерея требовать только broker_read_url - PullRequest
2 голосов
/ 19 июня 2020

https://docs.celeryproject.org/en/master/userguide/configuration.html#broker -read-url-broker-write-url

Когда я указываю только broker_read_url в celeryconfig.py, по какой-то причине сельдерей возвращается к значению по умолчанию amqp://localhost:5672

Для меня это не имеет смысла. Зачем работнику нужно , чтобы писать брокеру? Глядя на исходный код, я не вижу ничего, кроме опции очистки, которая потребовала бы этого.

Есть ли способ обойти это? Я попытался ввести фиктивный URL, но это не сработало.

edit: Подробнее о моей настройке. У меня настроена лопата rmq, на которую я пишу, и экземпляр rmq, из которого я читаю. В моем приложении производителя я хочу настроить только broker_read_url, а в потребляющем работнике я хочу настроить только broker_write_url.

Поскольку я не могу этого сделать, я предполагаю, что сельдерей должен использовать его для чего-то , но я не могу точно сказать, что просматривает код.

...