celery

0зной

1ответ

Python Celery task.delay() когда брокер Очередь заполнена

Я использую celery 4 с RabbitMQ в качестве брокера. Я ограничил Queue (размер == 200). Мой главный код выглядит следующим образом: for i in range(200): tasks.delay(i) Это работает, если диапазо

python-3.x celery 2017-01-10

---

0зной

1ответ

Если работник сельдерея тяжело умирает, повторится ли работа?

Есть ли способ для выполнения задания на сельдерей, если сервер, на котором работает рабочий, умирает? Я имею в виду не только подпроцесс, выполняющий эту работу, но весь сервер становится недоступным

redis rabbitmq celery 2017-01-10

---

1зной

1ответ

Завершить задачу сельдерея в задаче

Нужна ваша помощь. Как я могу запустить задачу сельдерея из кода с заданным интервалом времени (каждые 3 минуты), максимальными повторениями (после того, как задача с пятью попытками должна быть прекр

python django celery 2017-01-11

---

0зной

1ответ

После задержки сельдерея() называется, она занимает почти 5 до 10 секунд для задач, чтобы начать выполнение в рабочем

В настоящее время я работаю над приложением с следующей конфигурацией: Джанго 1,8 Python 2,7 сельдерея 3.1.x (Amazon SQS, как borker URL) Я в настоящее время работает с несколькими сельдереем каждый с

python django amazon-web-services celery amazon-sqs 2017-01-11

---

0зной

1ответ

Как установить и запустить сельдерей на окнах?

Привет и благодарю вас за ваше время У меня есть большой проект Django, и я разрабатываю его в PyCharm на Windows. Прямо сейчас мне нужно использовать интеллектуальные запросы, поэтому я хочу добавить

django celery 2017-01-12

---

0зной

1ответ

cell daemon using systemd не работает

Я использую ubuntu 16 и systemd для работы с сельдереем как daemon.i также создали файл блока, но я не могу запускать сельдерей в качестве сервиса. почему эта ошибка? /etc/systemd/system/celery.servic

celery ubuntu-16.04 systemd 2017-01-12

---

0зной

2ответ

unittest Задача сельдерея assertRaises

У меня есть задача сельдерея. Я хочу проверить его с помощью unittest. я делаю что-то очень похожее на: class TestMe(unittest.TestCase): def test_celery_task(self): self.assertRaises(ValueE

python unit-testing celery assert 2017-01-12

---

1зной

3ответ

сельдерей задача же график с офсетной

Я несколько задач, что-то вроде этого: CELERYBEAT_SCHEDULE = { 'task1': { 'task': 'api.tasks.task1', 'schedule': timedelta(seconds=10), }, 'task2': { 'task': 'api.task

python django celery crontab schedule 2017-01-13

---