Работа вокруг сельдерея, являющегося единственной точкой отказа

Я ищу рекомендуемое решение для обхода celerybeat, являющегося единственной точкой отказа для развертывания celery / rabbitmq. Пока что я не нашел ничего, что имело бы смысл, занимаясь поиском в Интернете. В моем случае один раз в день ...

Сельдерей бить с методом задачи не работает

Я пытаюсь запустить метод сельдерея на методической задаче и не могу заставить что-либо работать должным образом. Вот пример настройки: from celery.contrib.methods import task_method from celery import Celery, current_app celery=celery('tasks', ...

Может ли сельдерей использовать сельский планировщик без Django?

У меня есть небольшой план инфраструктуры, которыйне включают Джанго. Но из-за моего опыта работы с Django мне очень нравится Celery. Все, что мне действител...

Замена сельдерея на Хронос

Сельдерей остановить исполнение цепи

У меня есть задача check_orders, которая выполняется периодически. Он создает группу задач, так что я могу определить, сколько времени заняло выполнение задач, и выполнить что-то, когда все они выполнены (это цель res.join [1] и grouped_subs). ...

Celery Beat: ограничение до одного экземпляра задачи за раз

У меня есть стебель сельдерея и сельдерей (четыре рабочих), чтобы сделать несколько этапов обработки навалом. Одна из этих задач примерно такая: «для каждого X, для которого не было создано Y, создайте Y». Задача запускается периодически с ...

Сельдерей умирает с DBPageNotFoundError

График ритма сельдерея: выполнить задание мгновенно, когда начнется ритм сельдерея?

Как сделать две задачи взаимоисключающими в сельдерее?

Есть ли способ запретить запуск двух разных задач одновременно в Celery? Я думал о том, чтобы определить новую очередь с уровнем параллелизма = 1 и отправить...

Celery Beat: ограничение до одного экземпляра задачи за раз

У меня есть стебель сельдерея и сельдерей (четыре рабочих), чтобы сделать несколько этапов обработки навалом. Одна из этих задач примерно такая же, какдля ка...