Результаты поиска по запросу "celery"
Как заставить задачу сельдерея провалиться изнутри задачи?
В некоторых условиях я хочу, чтобы задача сельдерея провалилась из-за этой задачи. Я попробовал следующее: from celery.task import task from celery import states @task() def run_simulation(): if ...
Сельдерей - график периодических задач, начиная с определенного времени
Каков наилучший способ запланировать периодическое задание, начиная с определенной даты? (Я не использую cron для этого, учитывая, что мне нужно запланировать около ста удаленных rsyncs, где я вычисляю удаленное и локальное смещение, и ...
Создание очередей динамически с Celery
Я пишу менеджер списков рассылки, используя Django, Celery и RabbitMQ. Когда приходит сообщение, задача выполняется для каждого получателя. Все задачи отправляются в одну очередь, и один или несколько рабочих используют задачи из очереди, ...
Примеры Джанго и Сельдерея: Периодические Задачи
Я уже некоторое время бьюсь с документацией по Django / Celery и мне нужна помощь. Я хотел бы иметь возможность запускать периодические задачи с использованием django-сельдерея. Я видел в интернете (и в документации) несколько разных форматов и ...
Определить, доступен ли сельдерей
я используюСельдерей [http://celeryproject.org/]управлять асинхронными задачами. Однако иногда процесс сельдерея останавливается, что не приводит к выполнению ни одной из задач. Я хотел бы иметь возможность проверить состояние сельдерея ...
Как проверить статус задания в сельдерее?
Как проверить, выполняется ли задание в сельдерее (в частности, я использую celery-django)? Я прочитал документацию, и я погуглил, но я не вижу такой вызов: my_example_task.state() == RUNNINGМой вариант использования заключается в том, что у ...
Повторите задание Celery с экспоненциальным откатом
Для такой задачи: from celery.decorators import task @task() def add(x, y): if not x or not y: raise Exception("test error") return self.wait_until_server_responds(если оно выдает исключение, и я хочу повторить его со стороны демона, как ...
Как перезапустить работников из сельдерея изящно?
Выпуская новую сборку для обновления кода на рабочих, как мне изящно перезапустить работников сельдерея? Редактировать:То, что я намерен сделать, это что-то вроде этого. Работник работает, возможно, загружает файл размером 100 МБ на S3Новая ...
Создание работника Celery с использованием node.js
С помощьюУзел-сельдерей [https://github.com/mher/node-celery], мы можем разрешить узлу отправлять задания Celery в очередь задач. Как мы можем позволить узлу быть работником Celery и потреблять очередь?
Работа вокруг сельдерея, являющегося единственной точкой отказа
Я ищу рекомендуемое решение для обхода celerybeat, являющегося единственной точкой отказа для развертывания celery / rabbitmq. Пока что я не нашел ничего, что имело бы смысл, занимаясь поиском в Интернете. В моем случае один раз в день ...