Вопросы по теме 'celery-task'

result.wait() ничего не делает, кроме зависания и не дает 8 для результата=add.delay(4,4)
add — это задача из celery doc. Я просто так смущен, почему он не дает 8, как должен, а вместо этого ничего не делает, кроме как зависает.
717 просмотров
celery-task
schedule 16.10.2023
Задача сельдерея с атрибутом time_start в 1970 году
Проверка текущих запущенных задач Celery обнаруживает странную временную метку time_start : >> celery.app.control.inspect().active() {u'[email protected]': [{u'acknowledged': True, u'args': u'(...,)', u'delivery_info':...
4052 просмотров
python django redis celery celery-task
schedule 25.05.2022
Django 1.6 + RabbitMQ 3.2.3 + Celery 3.1.9 — почему мой рабочий celery умирает с: WorkerLostError: Worker вышел преждевременно: сигнал 11 (SIGSEGV)
Кажется, это решает очень похожую проблему, но не дает мне достаточного понимания: https://github.com/celery/billiard/issues/101 Похоже, было бы неплохо попробовать базу данных, отличную от SQLite... У меня есть простая настройка сельдерея с моим...
1851 просмотров
django rabbitmq celery celery-task celerybeat
schedule 11.06.2022
Цветок сельдерея - как я могу загрузить предыдущие пойманные задачи?
Я начал использовать цветок сельдерея для мониторинга задач, и он работает как шарм. Однако у меня есть одна проблема: как я могу «перезагрузить» информацию об отслеживаемых задачах после перезапуска цветка? Я использую Redis в качестве брокера, и...
1061 просмотров
python celery celery-task flower
schedule 05.08.2022
Внутри метода запуска класса задач сельдерея получить task_id
Я пытаюсь запустить следующий код: class myTask(Task): def run(): print myTask.request.id Но этот код дает None как request_id. Пожалуйста, объясните мне, почему я не могу прочитать идентификатор в классе задач сельдерея
803 просмотров
celery celery-task
schedule 08.04.2023
AsyncResult(task_id) возвращает состояние PENDING даже после запуска задачи
В проекте я пытаюсь опросить task.state длительной задачи и обновить ее статус выполнения. Это работало в разработке, но не будет работать, когда я перенесу проект на рабочий сервер. Я продолжал получать «ОЖИДАНИЕ», хотя вижу, что задача запущена на...
3413 просмотров
python django celery celery-task django-celery
schedule 07.11.2023
Незарегистрированная задача Celery KeyError
Я запускаю работника, выполнив в терминале следующее: celery -A cel_test worker --loglevel=INFO --concurrency=10 -n worker1.%h Затем я получаю длинное зацикливающееся сообщение об ошибке, в котором говорится, что сельдерей получил...
2444 просмотров
python rabbitmq asynchronous celery celery-task
schedule 09.09.2022
Связать задачи сельдерея с TimeLimitExceeded или сбоем
« worker_collect » — это пакет celery. Все задачи направляются в одну и ту же очередь. Я выполняю 2 задачи. Задача «сбор_данных» вызывает задачу « do_request ». Я установил sleep(5) , чтобы принудительно установить тайм-аут....
467 просмотров
celery celery-task
schedule 13.04.2022
Джанго с сельдереем: получение статуса выполняемой задачи
В настоящее время я тестирую Django с сельдереем. Периодическая задача настроена с помощью crontab для запуска следующей задачи: from __future__ import absolute_import from celery import task import time @task def add(x, y): print "Start...
428 просмотров
django celery celery-task django-celery djcelery
schedule 23.05.2022
Сельдерей: @shared_task и нестандартный BROKER_URL
У меня есть установка Celery 3.1.19, которая использует BROKER_URL, включая виртуальный хост. # in settings.py BROKER_URL = 'amqp://guest:guest@localhost:5672/yard' Celery запускается нормально, загружает задачи, и задачи, которые я определяю...
1630 просмотров
python rabbitmq celery-task
schedule 08.02.2023
Сельдерей - задача выполняется раньше, чем ее подзадачи
Я не могу понять, почему моя задача считается выполненной, пока не выполнены все ее подзадачи. tasks.scan_user.delay(1) КОД: @task() def scan_chunk(ids): occs = Occurence.objects.filter(product_id__in=ids) result =...
140 просмотров
python python-2.7 celery celery-task
schedule 02.05.2022
Сельдерей: понимание общей картины
Celery кажется отличным инструментом, но мне трудно понять, как различные компоненты Celery работают вместе: Рабочие Приложения Задачи Брокер сообщений (например, RabbitMQ) Насколько я понимаю, командная строка: celery -A...
603 просмотров
python celery celery-task django-celery
schedule 04.08.2022
Кто обрабатывает зависимости задач в celery-rabbitmq
Я действительно запутался здесь, как новичок в Celery, и хотел бы получить некоторые сведения о том, как сельдерей с брокером сообщений в качестве rabbitmq обрабатывает зависимости задач, когда клиент (ipython) отправляет DAG с использованием...
314 просмотров
rabbitmq celery celery-task
schedule 05.12.2022
Статус сельдерея застрял в статусе ожидания
Я нашел пример запуска сельдерея с mongodb в качестве бэкэнд-результата здесь original пример кода . В его примере у него есть CELERYBEAT_SCHEDULE с некоторыми параметрами для запуска каждую минуту, в моем случае я просто закомментировал этот код....
1115 просмотров
celery celery-task django-celery celerybeat celeryd
schedule 11.10.2022
Сельдерей с динамическими рабочими
Я собираю конвейер приема данных на основе Celery. Одна вещь, которую я нигде не вижу в документации, это то, как построить поток, в котором рабочие процессы выполняются только тогда, когда есть работа, которую нужно выполнить. (честно говоря,...
1092 просмотров
python-3.x celery celery-task flower
schedule 04.06.2023
Celery + Django не работают одновременно
У меня есть проект Django 2.0 , который работает нормально, он интегрирован с Celery 4.1.0 , я использую jquery для отправки запроса ajax на сервер, но я только что понял, что он загружается бесконечно из-за некоторых проблем с сельдереем....
1328 просмотров
django celery celery-task
schedule 05.05.2022
Сельдерей - не удается получить результаты задачи
Я использую Django ORM/Cache в качестве бэкэнда для сельдерея. Я вижу, что в базе данных создана таблица django_celery_results_taskresult . После завершения задач результаты также вставляются в базу данных, которую можно просмотреть из MySQL. Но...
998 просмотров
python django celery celery-task django-celery
schedule 24.01.2023
Как мы выполнили стоп-задачи в celery Period_Task?
Отзыв задачи на @periodic_task отправляет Discarding revoked tasks & Due task to workers. скриншот celery-workers [2018-09-17 12:23:50,864: INFO/MainProcess] Received task: cimexapp.tasks.add[xxxxxxx] [2018-09-17 12:23:50,864:...
2647 просмотров
django celery celery-task django-celery celerybeat
schedule 05.08.2022
Очистить предыдущую задачу celery redis, когда одна и та же задача запускается периодически
У меня есть скребок celery-beat, который периодически запускается для получения последних данных от определенного API (каждые 30 минут). Сегодня (14 декабря 2019 г.) я все еще вижу результаты в цветке сельдерея для задачи, запущенной за 5 дней...
168 просмотров
celery celery-task
schedule 15.06.2023
Как очистить все подзадачи сельдерея от родительской задачи?
В моем sharedtask я называю несколько subtasks(...).apply_async() . Таким образом, и родительская задача, и подзадачи имеют свой собственный task_id. Когда я отменяю всю операцию, я вызываю отзыв всех активных задач, и это работает правильно....
37 просмотров
python-2.7 celery celery-task
schedule 07.04.2023