0
ответов
Повторная попытка неудачных задач celery, которые являются частью цепочки
У меня есть цепочка сельдерея, которая выполняет некоторые задачи. Каждая из задач может потерпеть неудачу и быть повторена. Ниже приведен краткий пример :из задачи импорта сельдерея @task (ignore _result=True )def add (x, y, fail=True )...
вопрос задан: 20 August 2014 20:14
0
ответов
Как заставить сельдерей повторить попытку, используя того же воркера?
Я только начинаю работать с сельдереем в проекте Django и как бы застрял в этой конкретной проблеме: в основном, мне нужно распределить длительную задачу на разные рабочие. На самом деле задача ...
вопрос задан: 22 June 2014 23:10
0
ответов
Повторить задачи Celery с экспоненциальным отставанием
Для такой задачи: из celery.decorators импортировать задачу @task()
def add(x, y): если не x или не y: поднять Exception("ошибка теста") return self.wait_until_server_responds( если выдает...
вопрос задан: 14 June 2014 10:47
0
ответов
Рабочий сельдерей не повторяет задачу после вызова повторной попытки()
У меня есть задача :@celery.task (name='request _task', default _retry _delay=2,acks _late=True )def request _задача (данные ):попытка :если какое-то _условие :запрос _задача.повторная попытка ()...
вопрос задан: 13 June 2014 15:21
0
ответов
Как очистить все задачи определенной очереди с помощью сельдерея в python?
Как очистить все запланированные и запущенные задачи определенной очереди с помощью сельдерея в python? Вопросы кажутся довольно простыми, но, чтобы добавить, я не ищу код командной строки, у меня есть ...
вопрос задан: 5 June 2014 22:05
0
ответов
Celery создает новое соединение для каждой задачи
Я использую Celery с Redis для запуска некоторых фоновых задач, но каждый раз при вызове задачи создается новое подключение к Redis. Я на Heroku, и мой план Redis to Go позволяет использовать 10 подключений. Я...
вопрос задан: 3 May 2014 09:33
0
ответов
Как я могу сделать панель инструментов со всеми незаконченными задачами с помощью Сельдерея?
Я хочу иметь некоторое место, где я могу наблюдать все задачи ожиданий. Я не говорю о зарегистрированных функциях/классах как задачи, но фактические запланированные задания, для которых я мог отобразиться: имя...
вопрос задан: 13 January 2014 02:16
0
ответов
Мониторинг сельдерея, что мне использовать? [закрыто]
Я использую Django, Celery и Django-Celery. Я хотел бы отслеживать состояние / результаты своих задач, но я немного не понимаю, как это сделать. Использую ли я ./manage.py celeryev, ./manage.py celerymon, ./...
вопрос задан: 11 January 2014 19:41
0
ответов
Django, ImportError: нельзя импортировать имя Celery, возможен круговой импорт?
Я рассмотрел этот пример здесь: http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html Все мои задачи находятся в файлах с именем tasks.py. После обновления сельдерея и добавления файла ...
вопрос задан: 12 November 2013 22:49
0
ответов
Использовать стандартное ведение журнала Python в Celery
Мне нужно реализовать Celery в уже существующей системе. В предыдущей версии системы уже использовалось стандартное ведение журнала Python. Мой код похож на код ниже. Процесс один и процесс два не являются ...
вопрос задан: 9 August 2013 19:34
0
ответов
Как убрать задание из сельдерея с помощью Redis Broker?
Я добавил некоторую неправильную задачу в сельдерей с помощью Redis Broker, но теперь я хочу удалить неправильную задачу и не могу найти способ сделать это. Есть какие-то команды или API для этого?
вопрос задан: 18 June 2013 20:04
0
ответов
Как отправлять периодические задания в определенную очередь в Celery
По умолчанию Celery отправляет все задачи в очередь 'celery', но вы можете изменить это поведение, добавив дополнительный параметр: @task (queue = 'celery_periodic') def recalc_last_hour (): log.debug ('send new ...
вопрос задан: 6 June 2013 13:36
0
ответов
Heroku больше не поддерживает сельдерей?
Я, наконец, дошел до того, что у меня появилось немного свободного времени, и я хотел добавить Celery в свой проект Python / Flask на Heroku. Тем не менее, почти все упоминания о сельдерее из документов Heroku исчезли. Там ...
вопрос задан: 7 March 2013 07:21
0
ответов
Должны ли экземпляры объекта модели django передаваться сельдерею?
# models.py из django.db импортировать класс моделей Person (models.Model): first_name = models.CharField (max_length = 30) last_name = models.CharField (max_length = 30) text_blob = models.CharField (...
вопрос задан: 26 February 2013 00:26
0
ответов
Направить задачу celery в определенную очередь.
На моем сервере запущено два отдельных процесса celery, которыми управляет супервизор. Они настроены на прослушивание отдельных очередей как таковых:[программа:celeryd1] command=/path/to/celeryd --pool=solo --queues=...
вопрос задан: 24 October 2012 13:55
0
ответов
Неверный пользователь для supervisor'd celeryd
У меня есть некоторые периодические задачи, которые я запускаю с сельдереем (демонизированным супервизором), но после попытки создать каталог в домашнем каталоге для пользователя, который я установил для процесса супервизора, я получил сообщение "...
вопрос задан: 24 October 2012 13:47
0
ответов
Как программно генерировать записи celerybeat с помощью celery и Django
Я надеюсь, что смогу программно генерировать записи celerybeat и повторно синхронизировать celerybeat при добавлении записей. В документах указано, что по умолчанию записи берутся из ...
вопрос задан: 4 October 2012 11:31
0
ответов
كيفية تشخيص عاملات الكرفس التي تتدلى
بدأت في استخدام الكرفس في مشروع Django. لأغراض التنمية المحلية ، قمت بإعداده باستخدام djcelery و djkombu (نقل قاعدة البيانات) ، وفقًا لهذه الإرشادات http: //ask.github ....
вопрос задан: 3 October 2012 17:01
0
ответов
Расписание задач Celery (Обеспечение выполнения задачи только по одной за раз)
У меня есть задача, примерно такая :@task ()def async _work (info ):... В любой момент я могу вызвать async _work с некоторой информацией. По какой-то причине мне нужно убедиться, что только одна асинхронная работа _выполняется в...
вопрос задан: 17 August 2012 09:30
0
ответов
Динамическое изменение настроек ритма сельдерея
Есть ли способ заставить celerybeat изменить настройки для конкретной задачи во время ее выполнения? Полезность этого лучше всего проиллюстрирована в этом примере :У меня есть периодическая задача, которая проверяет значение...
вопрос задан: 15 August 2012 21:36
0
ответов
Может ли celery worker/server принимать задачи от производителя, не являющегося celery?
Я хочу использовать комет-сервер, написанный с использованием java nio, для отправки обновлений в реальном времени. При получении информации я хочу, чтобы она сканировала данные и отправляла задачи рабочим потокам через rabbitmq. В идеале я бы...
вопрос задан: 15 August 2012 06:02
0
ответов
Celery :Одноэлементная задача?
У меня есть задача, которую мне нужно запустить асинхронно с веб-страницы, вызвавшей ее. Эта задача выполняется довольно долго, и, поскольку веб-страница может получать много таких запросов, я бы хотел, чтобы сельдерей выполнял только...
вопрос задан: 11 August 2012 04:16
0
ответов
Зависит ли количество процессов celeryd от настройки параллелизма --?
Мы запускаем Celery за Supervisor и запускаем его с celeryd --events --loglevel=INFO --concurrency=2 Это, однако, создает граф процесса, который имеет глубину до трех слоев и содержит до 7...
вопрос задан: 1 August 2012 09:07
0
ответов
Установка ограничения по времени для конкретной задачи с сельдереем
У меня есть задача в Celery, которая потенциально может выполняться в течение 10 000 секунд при нормальной работе. Однако все остальные мои задачи должны быть выполнены менее чем за одну секунду. Как установить ограничение по времени...
вопрос задан: 26 July 2012 14:59
0
ответов
Я хочу использовать gevent.evnet в celery.task
Я долго работал над системой опроса -. Я использую флягу + монгокит + сельдерей + гевент. Когда процесс в задаче сельдерея завершен, gevent.event.set ()не работает. поэтому хочу помочь разобраться. (В...
вопрос задан: 16 July 2012 09:54
0
ответов
Ошибки кадрирования в Celery 3.0.1
Недавно я обновился до Celery 3.0.1 с 2.3.0, и все задачи выполняются нормально. К сожалению. Я довольно часто получаю исключение «Ошибка кадра». Я также запускаю супервизора для перезапуска потоков...
вопрос задан: 13 July 2012 23:34
0
ответов
Django -celery :Передача объекта запроса рабочему
Как я могу передать объект запроса django рабочему сельдерея. Когда вы пытаетесь передать объект запроса, он выдает ошибку «Не удается собрать входные объекты». Кажется, что сельдерей сериализует любые аргументы, переданные рабочему процессу....
вопрос задан: 11 July 2012 08:33
0
ответов
Сельдерей или бобовый стебель или и то, и другое?
Я знаю (, но не понимаю ), что Celery может использовать Beanstalk в качестве механизма доставки. С домашней страницы Beanstalkd «Beanstalk — это простая и быстрая рабочая очередь». С домашней страницы сельдерея «Это задача...
вопрос задан: 9 July 2012 15:58
0
ответов
Celery Получено незарегистрированная задача типа (пример запуска)
Я пытаюсь запустить пример из документации Celery. Я запускаю: celeryd --loglevel=INFO /usr/local/lib/python2.7/dist-packages/celery/loaders/default.py:64: NotConfigured: Модуль celeryconfig не найден!...
вопрос задан: 27 June 2012 11:00
0
ответов
Запуск задачи Python Celery через Redis Pub/Sub
Есть ли эффективный способ запускать задачи через Redis Pub/Sub и возвращать значение задачи обратно в канал Pub/Sub для запуска другой задачи на основе результата? Есть ли у кого-нибудь идея, как ...
вопрос задан: 23 June 2012 08:19