0
ответов
Выполнение задач Celery с граф зависимостей
Я хотел бы иметь задачи Celery, которые зависят от результата 2 или более других задач. Я изучил Python + Celery: объединение заданий? и http://pypi.python.org/pypi/celery-tasktree, но это ...
вопрос задан: 23 May 2017 12:18
0
ответов
python celery max-tasks-per-child-setting default
Я использую сельдерей и хочу использовать max-tasks-per-child-setting
потому что некоторые процессы сельдерея потребляют много памяти. Я пытаюсь найти значение по умолчанию для этого параметра, прежде чем изменить...
вопрос задан: 23 May 2017 12:16
0
ответов
Хаки для интеграции с сельдереем Tornado
Поскольку никто не предоставил решение для этого сообщения, плюс тот факт, что мне отчаянно нужен обходной путь , вот моя ситуация и некоторые абстрактные решения / идеи для обсуждения. Мой стек: Tornado
Celery
MongoDB
...
вопрос задан: 23 May 2017 12:15
0
ответов
Почему CeleryCAM не работает с Amazon SQS?
Я использую Celery 2.4.6 и django-celery 2.4.2. Когда я настраиваю Celery для использования Amazon SQS в соответствии с решением по этому вопросу: Celery с Amazon SQS, я ничего не вижу в таблице celerycam в ...
вопрос задан: 23 May 2017 12:15
0
ответов
Celery + Django: не удается запустить celerybeat в Windows 7
Здесь возникают странные проблемы. Я разрабатываю приложение Django и сейчас пытаюсь реализовать Celery. Мне нужно, чтобы в очереди стояли как обычные, так и периодические задачи. Я могу запустить celeryd просто отлично, и ...
вопрос задан: 23 May 2017 12:02
0
ответов
django celery завершает подпроцессы задачи
Это дополнительный вопрос к моему предыдущему вопросу:
Отменить уже выполняющуюся задачу с помощью Celery? celery.task.control.revoke ({task_id}, terminate = True) действительно убивает моего рабочего, выполняющего задачу ....
вопрос задан: 23 May 2017 11:53
0
ответов
Использование ORM Django в задаче Celery
Как задача Celery может получить доступ к API абстракции базы данных Django? Нужно ли это кодировать с нуля, используя одну из стратегий для автономного использования ORM Django, или есть еще ...
вопрос задан: 23 May 2017 11:45
0
ответов
Настройка экземпляров EC2 в качестве Celery Workers с локальным компьютером в качестве хоста
Как и в моем вопросе, я пытаюсь настроить несколько экземпляров amazon EC2 для выполнения некоторой многопроцессорной обработки. Я думал об использовании сельдерея для управления рабочими. Кто-нибудь заставил сельдерей работать на EC2 ...
вопрос задан: 23 May 2017 10:33
0
ответов
Есть ли в Python распределенная очередь задач, которая позволяет мне убивать зависшие задачи, которые не желают сотрудничать
В основном у меня много задач (партиями примерно по 1000), и время выполнения этих задач может сильно различаться ( от менее секунды до 10 минут). Я знаю, что если задача выполняется более ...
вопрос задан: 23 May 2017 10:24
0
ответов
celery .delay зависает (недавно, не проблема авторизации)
Я использую Celery 2.2.4 / djCelery 2.2.4, используя RabbitMQ 2.1.1 в качестве бэкэнда. Я недавно подключил два новых сервера сельдерея - у меня было 2 рабочих на двух машинах, всего ~ 18 ...
вопрос задан: 23 May 2017 10:00
0
ответов
Django celery получает статус задачи с помощью Ajax
Я использую сельдерей 2.5.3 и сельдерей django -2.5.5. И я использую mysql в качестве брокера. Вот сценарий, когда пользователь запрашивает задание, которое я ставлю в очередь на работника, который получает данные с другого сайта....
вопрос задан: 5 January 2017 06:18
0
ответов
Python + Celery: объединение заданий в цепочку?
Документация по Celery предполагает, что не стоит заставлять задачи ждать результатов других задач… Но предлагаемый Решение (см. заголовок «хорошее») оставляет желать лучшего. В частности, ...
вопрос задан: 22 December 2016 21:19
0
ответов
Установка периодических задач в Celery (celerybeat) динамически с помощью add_periodic_task
Я использую Celery 4.0.1 с Django 1.10, и у меня возникают проблемы с планированием задач (выполнение задачи работает нормально). Вот конфигурация сельдерея: os.environ.setdefault ('DJANGO_SETTINGS_MODULE', 'myapp ....
вопрос задан: 22 December 2016 09:33
0
ответов
Почему сельдерей возвращает ошибку KeyError при выполнении моей задачи?
Я продолжаю получать эту ошибку keyError. Я отправляю строки и id (целые числа) в функцию задачи, поэтому не думаю, что это проблема сериализации. Также он говорит, что keyerror находится на пути к самой функции, ...
вопрос задан: 11 May 2016 22:31
0
ответов
Сельдерей джанго: Ошибка соединения с потребителем (Consumer Connection Error) (111) при запуске python manage.py celeryd
Я пытаюсь настроить проект Django на использование сельдерея (я использую Django 1.3 в Debian Squeeze) Я установил django-celery (2.3.3), а затем последовал этим инструкциям. Настройки моего сельдерея ...
вопрос задан: 6 February 2016 02:25
0
ответов
Основанные на Python модули асинхронного рабочего процесса: в чем разница между рабочим процессом сельдерея и рабочим процессом луиджи?
Я использую Django в качестве веб-фреймворка. Мне нужен механизм рабочего процесса, который может выполнять как синхронную, так и асинхронную цепочку задач. Я нашел сельдерей и Луиджи в качестве рабочего процесса пакетной обработки. Мой ...
вопрос задан: 29 January 2016 16:29
0
ответов
Сельдерей - Программный список рабочих
Как я могу программно, используя код Python, перечислить текущих работников и их соответствующие экземпляры celery.worker.consumer.Consumer?
вопрос задан: 19 December 2015 18:41
0
ответов
Учебник Django Celery не возвращает результаты
UDATE3: обнаружил проблему. См. Ответ ниже. UPDATE2: Кажется, я мог иметь дело с проблемой автоматического именования и относительного импорта, запустив учебник djcelery через manage.py. ..
вопрос задан: 19 December 2015 11:27
0
ответов
Запуск пауков Scrapy в задаче Celery
У меня есть сайт Django, на котором происходит очистка, когда пользователь запрашивает его, и мой код запускает автономный скрипт Scrapy Spider в новом процессе. Естественно, это не работает с увеличением пользователей....
вопрос задан: 19 December 2015 09:04
0
ответов
Отменить уже y выполнение задачи с помощью Celery?
Я читал документацию и выполнял поиск, но не могу найти прямого ответа: можно ли отменить уже выполняющуюся задачу? (так как задача запущена, занимает некоторое время и выполняется на полпути ...
вопрос задан: 5 November 2015 17:47
0
ответов
celery task и customize decorator
Я работаю над проектом с использованием django и celery (django-celery). Наша команда решила обернуть весь код доступа к данным в (app-name) /manager.py (НЕ оборачивать менеджеров, как в django), и впустить код ...
вопрос задан: 30 October 2015 13:48
0
ответов
Сельдерей: проверьте, выполнено ли задание без сохранения результатов.
Я хотел бы знать, когда некоторые задачи закончили выполняться, чего я могу достичь в сельдерее с помощью: task.ready (). Мне действительно не нужны фактические результаты, мне нужно только знать, выполняются ли задачи ...
вопрос задан: 25 February 2015 16:31
0
ответов
Увеличьте время повтора сельдерея в каждом цикле повтора
Я делаю повторы с сельдереем, как в Docs-Example: @task () def add (x, y): try: ... кроме исключения, exc: add.retry (exc = exc, countdown = 60) # переопределяет значение по умолчанию а также ...
вопрос задан: 26 November 2014 08:03
0
ответов
Удаление всех ожидающих задач в celery / rabbitmq
Как я могу удалить все ожидающие задачи, не зная task_id для каждой задачи?
вопрос задан: 21 November 2014 02:49
0
ответов
Как заставить задачу сельдерея провалиться изнутри задачи?
В некоторых условиях я хочу, чтобы задача сельдерея провалилась из-за этой задачи. Я попробовал следующее: из задачи импорта celery.task из состояния импорта сельдерея @task () def run_simulation (): if ...
вопрос задан: 10 November 2014 14:11
0
ответов
django-celery без сервера amqp (rabbitmq)
Я использую сельдерей для обработки распределенных задач. Я хотел развернуть свою работу на веб-хостинге, просто чтобы показать, как работает мой проект.
Итак, как я могу заставить djcelery использовать базу данных (sqlalchemy) в качестве бэкэнда ...
вопрос задан: 6 November 2014 12:09
0
ответов
Сигналы Django в сельдерее
У меня есть задача, которая выполняется в экземпляре Celerybeat. Когда эта задача выполняется, она иногда изменяет объект модели, который должен запускать сигнал post / pre_save, но этого не происходит. Сигнал не ...
вопрос задан: 22 October 2014 05:23
0
ответов
Узнать, существует ли задача celery
Можно ли узнать, существует ли задача с определенным идентификатором задачи? Когда я пытаюсь получить статус, я всегда получаю ожидание. >>> AsyncResult('...').статус
'PENDING' Я хочу знать...
вопрос задан: 9 October 2014 19:23
0
ответов
Сельдерей: доступ к времени последнего запуска задачи?
Можно ли с помощью сельдерея изнутри задачи проверить, когда последний раз эта задача была запущена? Я хотел бы реализовать «захватить все с момента последнего запуска». Я могу либо отслеживать ...
вопрос задан: 8 October 2014 07:44
0
ответов
Как правильно настроить серверную часть результатов djcelery для базы данных
Я пытаюсь настроить djangocelery для хранения результатов задач в базе данных. Я установил: CELERY_RESULT_BACKEND = 'djcelery.backends.database.DatabaseBackend', затем я синхронизировал и перенес базу данных (без ошибок). ...
вопрос задан: 28 September 2014 14:50