Зависит ли количество процессов celeryd от параметра --concurrency?

Мы запускаем Celery за Supervisor и начинаем с

Лучший способ сопоставить сгенерированный список с задачей в сельдерее

Лучший способ сопоставить сгенерированный список с задачей в сельдерее

Я ищу несколько советов о том, как лучше сопоставить список, созданный из задачи, с другой задачей в сельдерее. Допустим, у меня есть задача под названиемparse, который анализирует документ PDF и выводит список страниц. Затем каждая страница ...

Как работник из сельдерея, потребляющий несколько очередей, решает, какой из них потреблять первым?

Я использую Celery для выполнения асинхронных фоновых задач с Redis в качестве бэкэнда. Я'Меня интересует поведение работника сельдерея в следующих ситуа...

Сбой узла сельдерея, на pidbox уже используется при перезапуске

у меня есть сельдерей, работающий с rabbitmq брокером. Сегодня у меня сбой узла сельдерея - он не выполняет задачи и не отвечает на

Как работник из сельдерея, потребляющий несколько очередей, решает, какой из них потреблять первым?

Я использую Celery для выполнения асинхронных фоновых задач с Redis в качестве бэкэнда. Меня интересует поведение работника из сельдерея в следующих ситуациях: Я работаю как рабочий демонceleryd, Этому работнику были назначены две очереди для ...

Сбой узла сельдерея, на pidbox уже используется при перезапуске

у меня есть сельдерей, работающий с rabbitmq брокером. Сегодня у меня сбой узла сельдерея - он не выполняет задачи и не отвечает наservice celeryd stop команда. После нескольких повторов узел остановился, но при запуске я получаю ...

stackoverflow.com/questions/11926077/...

ся, чем дольше я работаю на своем сервере rabbitmq, тем больше у меня проблем с неподтвержденными сообщениями. Я хотел бы потребовать их. На самом деле, кажется, для этого есть команда amqp, но она применяется только к каналу, который использует ...

Увеличьте время повтора сельдерея в каждом цикле повтора

Я делаю повторы с сельдереем, как в Docs-примере: @task() def add(x, y): try: ... except Exception, exc: add.retry(exc=exc, countdown=60) # override the default and # retry in 1 minuteКак я могу увеличивать время повторного отсчета каждый раз, ...

Понимание предварительной выборки сельдерея

Я только что узнал о параметре конфигурации (