Результаты поиска по запросу "celery"
Измерение времени выполнения задачи сельдерея
Я преобразовал автономную пакетную работу, чтобы использовать сельдерей для отправки работы, которую нужно сделать. Я использую RabbitMQ. Все работает на одной машине, и никакие другие процессы не используют экземпляр RabbitMQ. Мой скрипт просто ...
Я потратил 2 дня, чтобы решить ее, но до сих пор не поблагодарил вас!
я пытался запустить работника, у меня возникла проблема: ImportError: Нет модуля с именем 'project' Traceback (последний вызов был последним): File "/usr/local/bin/celery", line 11, in <module> sys.exit(main()) ...
Вот
устил приложение фляги с работником сельдерея и перерисовал в трех отдельных контейнерах докера без каких-либо проблем. Вот как я начинаю это: celery worker -A app.controller.engine.celery -l info --concurrency=2 --pool eventlet Сельдерей ...
Я надеюсь, что смогу помочь кому-то с этим ответом, кто сталкивается с подобными проблемами с регистрацией python, spunk и сельдерея! :)
я есть скрипт Python, работающий на сервере, который должен запускаться раз в день планировщиком сельдерея. Я хочу отправить свои логи прямо из скрипта на спленк. Я пытаюсь использовать ...
Вы можете убить всех работников сельдерея просто:
я есть 2 вида задач: Тип 1 - Несколько небольших задач с высоким приоритетом. Тип 2 - Много тяжелых задач с более низким приоритетом. Первоначально у меня была простая конфигурация с маршрутизацией по умолчанию, ключи маршрутизации не ...
РЕДАКТИРОВАТЬ: после тестирования я обнаружил, что это только частичное решение. Размер зарезервированного ограничен настройкой предварительной выборки для работника.
могу получить список задач в очереди, которые еще предстоит обработать?
Таким образом, вы говорите сельдерею использовать django db для задач расписания.
я запускаю syncdb, я замечаю много таблиц, созданных как: djcelery_crontabschedule...djcelery_taskstatedjango-kombu предоставляет транспорт, поэтому он не может быть связан с реальной очередью. Даже когда я запускаю задачи, я все еще не вижу ...
А потом:
еопределяю метод save () модели для вызова асинхронной задачи с Celery. Эта задача также спасает модель, и поэтому я сталкиваюсь с рекурсивной ситуацией, когда задача Celery вызывается неоднократно. Вот код: Метод сохранения модели: def ...
Для упомянутой ошибки IOError, хотя приведенной здесь информации недостаточно, чтобы сказать, что ее вызвало, я предполагаю, что вы пытались установить соединение внутри функции задачи, поэтому всякий раз, когда вызывается задача, создается новое соединение. Если задача будет вызвана тысячу раз, будет тысяча соединений. Это затопит системный менеджер сокетов, и IOError является его жалобой.
ользую сельдерея для запуска основной задачи, которая запускает ряд дополнительных задач. У меня есть обе задачи уже написаны. Есть ли способ легко сделать это? Позволяет ли Celery запускать задачи изнутри? Мой пример: @task def ...
https://github.com/celery/celery/tree/master/examples/gevent
у приложение на Python, которое требует одновременности и асинхронности. У меня было несколько рекомендаций для Twisted и Celery, но у меня возникли проблемы с определением, какой из них лучше подходит для этого приложения (у меня нет ...