Описание тега celery-task
NoneCelery-task is a building block of Celery distributed task queue system
1
ответ
Почему в заданиях по сельдерею для сельдерея нужны названия?
В документации декоратору @celery.task не передаются аргументы, но в примере с GitHub он называется "tasks.add". Почему это? Когда я удаляю имя, пример больше не работает, жалуясь на KeyError: '__main__.add' [1] http://flask.pocoo.org/docs/0.10/patt…
09 окт '14 в 07:31
1
ответ
Сельдерей Создание групповых задач из цепочки задач
Я пытаюсь связать следующие задачи с сельдереем (v4.0), task = group([tasks1.s(), task2.s()) | generate_job_requests.s() | execute_job.map() | aggregate_result.s() result = task.get() Выше часть работает нормально до generate_job_requests как аккорд…
13 ноя '16 в 07:14
0
ответов
Сельдерей - Индивидуальный набор результатов каждой группы в цепочке
У меня есть периодическое задание, которое дает мне вновь добавленные пользователи говорят каждые 100 секунд. Я хочу выполнить две разные задачи в списке пользователей, полностью независимых друг от друга. Я настроил две очереди, используя celery_ro…
10 окт '17 в 17:58
1
ответ
Получить результат из 'task_id' в Celery из неизвестного задания
Как вытащить результат задачи, если я не знаю ранее, какая задача была выполнена? Вот настройка: Учитывая следующий источник ('tasks.py'): from celery import Celery app = Celery('tasks', backend="db+mysql://u:p@localhost/db", broker = 'amqp://guest:…
24 июн '14 в 15:48
1
ответ
Сельдерей: выполнить задание после определенного промежутка времени
Я хочу отправить электронное письмо своим пользователям ровно через 48 часов после их регистрации. Как мне добиться этого с помощью сельдерея? Если я создаю периодическое задание для отправки электронного письма, мне нужно будет выбрать конкретное в…
04 июн '14 в 10:48
0
ответов
Сценарий Node.js (узел-сельдерей) вызов задачи сельдерея неправильно обрабатывает аргумент "себя"
Я создал скрипт задачи сельдерея следующим образом: from celery import Task from celery.contrib.methods import task from celery.contrib.methods import task_method from pipelines.addsub import settings from pipelines.addsub.log import register_task_l…
13 сен '14 в 18:51
3
ответа
Возможное состояние гонки между сигналом Django post_save и задачей сельдерея
В приложении django 2.0 у меня есть модель под названием Document, которая загружает и сохраняет изображение в файловой системе. Эта часть работает. Я выполняю некоторое распознавание лиц на изображении, используя https://github.com/ageitgey/face_re…
27 ноя '18 в 15:56
4
ответа
Ошибка импорта в сельдерее
Это код, который я запускаю: from __future__ import absolute_import from celery import Celery celery1 = Celery('celery',broker='amqp://',backend='amqp://',include=['tasks']) celery1.conf.update( CELERY_TASK_RESULT_EXPIRES=3600, ) if __name__ == '__m…
30 окт '13 в 04:09
0
ответов
Сельдерей: опция 'очереди' из подписи, не распространяющейся на холсте
У нас есть настройка, в которой задачи выполняются в разных очередях у разных работников: @cel.task(bind=true, acks_late=true, queue='A') def taskA(self): pass @cel.task(bind=true, acks_late=true, queue='B') def taskB(self): pass У нас есть два рабо…
04 дек '18 в 07:22
1
ответ
Запустить задачу сельдерея с помощью команды управления django
Я пытаюсь запустить задачу, используя celery 3.1, из пользовательской команды управления. Если я вызываю мою задачу из представления, она работает нормально, но при запуске той же задачи из моей команды управления, задача будет выполняться синхронно…
16 дек '15 в 09:26
1
ответ
Цепь сельдерея разрывается, если одна из задач не выполняется
Какой смысл в цепочке Celery, если вся цепочка обрывается, если одна из задач не выполняется?!! У меня есть эта сеть сельдерея: res = chain(workme.s ( y=1111 ), workme2.s( 2222 ), workme3.s( 3333 ),)() И я сделал workme2 терпит неудачу с повторениям…
25 июн '13 в 07:13
1
ответ
Рабочий из сельдерея ImportError: Нет модуля с именем 'project'
Пока я пытался запустить работника, у меня возникла проблема:ImportError: нет модуля с именем 'project' Traceback (последний вызов был последним): File "/usr/local/bin/celery", line 11, in <module> sys.exit(main()) File "/usr/local/lib/python3…
06 сен '18 в 19:01
0
ответов
Сложное полотно застревает в середине
Настройка: Celery 4.1.0, брокер =RabbitMQ 3.6.5, серверная часть =Redis 3.2.5 Рассмотрим следующий холст: celery worker -A worker.celeryapp:app -l info -Q default -c 2 -n defaultworker@%h -Ofair @app.task(name='task_1', bind=True, base=MyConnectionH…
27 июл '17 в 10:29
3
ответа
Сбой задачи Celery (Django + Redis): "Невозможно установить соединение, потому что целевая машина активно отказала ему"
ОБНОВЛЕНИЕ: Я решил попробовать использовать Django в качестве брокера для простоты, так как я предположил, что сделал что-то не так в настройке Redis. Однако после внесения изменений, описанных в документации, я получаю ту же ошибку, что и ниже, пр…
16 янв '16 в 19:08
1
ответ
Сельдерей с брокером Redis не может выполнить задачу Django
В эти дни я изучаю Python(2.7)/Django(1.5), разрабатывая свой собственный клон Reddit (на Ubuntu 14.04 LTS). Я пытаюсь включить в микс Celery(3.1) с Redis, используя его для периодического запуска алгоритма ранжирования в качестве задачи (на моей ло…
04 июн '15 в 14:09
1
ответ
Лимит на питон сельдере эта?
Есть ли у сельдерея ограничение на выполнение задания? Я хочу выполнить метод foo через 12 дней у сельдерея будут проблемы с этим? Или мне нужно настроить какие-либо настройки Celery для такого длинного эта? next_run = datetime.now() + timedelta(day…
16 дек '15 в 13:46
0
ответов
Аккорд динамически созданной группы не называется
Недавно узнал о сельдерее task.replace и пытаясь использовать его силу, я столкнулся с загадочной ситуацией, которая согласно документации Celery (и различным вопросам Pull-Requests/SO, лежащим в Интернете) - должна сработать.Допустим, у меня есть с…
27 мар '17 в 19:48
2
ответа
Сельдерей add_periodic_task блокирует работу Django в среде uwsgi
Я написал модуль, который динамически добавляет периодические задачи сельдерея на основе списка словарей в настройках проекта (импортируется через django.conf.settings). Я делаю это с помощью функции add_tasks который планирует функцию для вызова с …
13 ноя '17 в 11:32
4
ответа
Получить имя работника сельдерея из задачи сельдерея?
Я хотел бы, чтобы задача сельдерея могла получить имя работника, выполняющего его, для целей регистрации. Мне нужно справиться с этим изнутри задачи, а не напрямую обращаться к брокеру. Есть ли способ сделать это? Я использую сельдерей с RabbitMQ, е…
25 май '14 в 15:37
1
ответ
Проверьте, если в задаче сельдерея
Как проверить, что функция выполняется в сельдерее? def notification(): # in_celery() returns True if called from celery_test(), # False if called from not_celery_test() if in_celery(): # Send mail directly without creation of additional celery subt…
16 дек '15 в 13:23