celery-task

3зной

1ответ

Колба сельдерея update_state изнутри другая функция

Я хотел бы обновить состояние моей задачи Celery от другой функции. Вот что у меня сейчас: Маршрут @app.route('/my-long-function', methods=['POST']) def my_long_function(): param1 = request.for

flask celery celery-task 2016-10-26

---

0зной

1ответ

Работник не может получить новую вставку данных в mysql в задачу колба сельдерея

У меня есть три сервера, которые запускают мою программу, и на каждом сервере есть восемь работников сельдерея, чтобы получить задание от redis. То есть задача сервера сельдерея может выполняться друг

python flask celery celery-task celeryd 2016-11-04

---

0зной

1ответ

Периодическая задача в сельдерее с использованием python без django

Привет всем, я новичок в сельдерее и питоне. Я создаю простую задачу с помощью rabbitmq-сервера. Но я понятия не имею, как добиться периодической задачи, используя бинт сельдерея в python. Я ищу, но к

python-2.7 celery-task celerybeat 2016-12-28

---

1зной

1ответ

Почему эта конструкция группы цепей вызывает исключение в сельдерее?

Я заранее извиняюсь за то, что не предоставил MVCE - к сожалению, из-за характера этого вопроса, он не поддается минимальным примерам. Я думаю, что он все равно будет нести ответственность без MVCE. У

python python-3.x asynchronous celery celery-task 2016-12-29

---

0зной

1ответ

сельдерея задача Создания группы из цепи задачи

Я пытаюсь цепи следующих задач с сельдереем (v4.0), task = group([tasks1.s(), task2.s()) | generate_job_requests.s() | execute_job.map() | aggregate_result.s() result = task.get() Выше часть работа

python celery celery-task 2016-11-13

---

0зной

1ответ

сельдерея вариант планирования бить немедленно запустить задачу после запуска сельдерея

я могу запланировать почасовую задачу в моем приложении Django с помощью сельдерея бить в settings.py так: CELERYBEAT_SCHEDULE={ 'tasks.my_task':{ 'task':'tasks.my_task', 'schedule':timedelta(secon

celery django-celery celery-task celerybeat 2017-01-04

---