9
ответов
колба сельдерея получить задание статус задачи в реальном времени [дубликат]
все, что я использую флягу, и я ищу способ отображения в конечном итоге в таблице статуса работы сельдерея. Я придумал решение, которое работает только наполовину. У меня есть mongodb работает как моя ...
вопрос задан: 27 January 2012 15:49
2
ответа
Как ждать результатов от сельдерея в Джанго
У меня есть задача сельдерея, которая отправляет данные в другой сервис. Я добавил задачу сельдерея send_inventory_request в представление на основе класса RequestSupplyStock. когда я делаю пост, я должен сначала получить результаты ...
вопрос задан: 18 January 2019 09:03
1
ответ
Прерывание выполняющейся задачи в Celery внутри django
Я хотел бы иметь возможность прервать выполнение задачи, выполняющейся из очереди Celery (с использованием rabbitMQ). Я вызываю задачу, используя task_id = AsyncBoot.apply_async (args = [name], name = name, connect_timeout = 3), где ...
вопрос задан: 26 August 2010 15:11
0
ответов
Как использовать группу и цепочки сельдерея для достижения сочетания синхронных и асинхронных задач?
Я хочу создать задачу A сельдерея, которая сама создает задачи, скажем X, Y, Z и т. Д., И они должны выполняться асинхронно. Задача A должна дождаться завершения задач X, Y, Z и возврата результатов. ...
вопрос задан: 19 March 2019 09:37
0
ответов
python celery max-tasks-per-child-setting default
Я использую сельдерей и хочу использовать max-tasks-per-child-setting
потому что некоторые процессы сельдерея потребляют много памяти. Я пытаюсь найти значение по умолчанию для этого параметра, прежде чем изменить...
вопрос задан: 23 May 2017 12:16
0
ответов
Удаление всех ожидающих задач в celery / rabbitmq
Как я могу удалить все ожидающие задачи, не зная task_id для каждой задачи?
вопрос задан: 21 November 2014 02:49
0
ответов
Как заставить задачу сельдерея провалиться изнутри задачи?
В некоторых условиях я хочу, чтобы задача сельдерея провалилась из-за этой задачи. Я попробовал следующее: из задачи импорта celery.task из состояния импорта сельдерея @task () def run_simulation (): if ...
вопрос задан: 10 November 2014 14:11
0
ответов
Повторная попытка неудачных задач celery, которые являются частью цепочки
У меня есть цепочка сельдерея, которая выполняет некоторые задачи. Каждая из задач может потерпеть неудачу и быть повторена. Ниже приведен краткий пример :из задачи импорта сельдерея @task (ignore _result=True )def add (x, y, fail=True )...
вопрос задан: 20 August 2014 20:14
0
ответов
Как убрать задание из сельдерея с помощью Redis Broker?
Я добавил некоторую неправильную задачу в сельдерей с помощью Redis Broker, но теперь я хочу удалить неправильную задачу и не могу найти способ сделать это. Есть какие-то команды или API для этого?
вопрос задан: 18 June 2013 20:04
0
ответов
Где вы устанавливаете идентификатор задачи _задачи celery?
У меня возникли проблемы с поиском примера установки идентификатора задачи _с идентификатором моей собственной задачи _что-то в этом роде... def testview1 (request ):for i in xrange (0,1000 ):result = add.delay (i, 4,...
вопрос задан: 19 April 2012 19:13
0
ответов
Сбросить обратный отсчет в задаче Celery
Мне нужно, чтобы задача celery запускалась после обратного отсчета, но иметь возможность сбросить этот обратный отсчет при определенных условиях. Например, я хочу вызвать apply_async с обратным отсчетом=15, но если произойдет определенное событие...
вопрос задан: 6 March 2012 23:52
0
ответов
Реализация Django Celery - OSError: [Errno 38] Функция, не реализованная
Я установил django-сельдерей, и я пытался запустить сервер рабочего, но я получаю OSError, что функция не реализована. Я выполняю выпуск 5.4 CentOS (Финал) на VPS:. брокер-> amqp://...
вопрос задан: 17 May 2011 17:40
0
ответов
Можно ли прервать вызов Java RMI?
Мы делаем некоторую работу по созданию прототипа, и нам интересно, можно ли прервать поток, выполняющий вызов RMI. Если мы вызовем interrupt () в этом потоке, вызовет ли это исключение InterruptedException? ...
вопрос задан: 28 February 2011 10:20
0
ответов
Проверить, обрабатывается ли еще задача сельдерея
Как я могу проверить, обрабатывается ли еще задача (task_id) в сельдерее? У меня следующий сценарий: Запустить задачу в представлении Django
Сохраните BaseAsyncResult в сеансе
Выключить демон сельдерея (жестко) ...
вопрос задан: 2 December 2010 13:36
0
ответов
Использование Django Celery AbortableTask
Я пытаюсь использовать функцию AbortableTask в Celery, но пример документации, похоже, не работает для меня. Приведенный пример: из celery.contrib.abortable import AbortableTask def ...
вопрос задан: 7 September 2010 14:26