celery- все статьи тега


Колба с create app, SQLAlchemy и сельдереем

Я действительно изо всех сил пытаюсь получить правильную настройку для колбы, SQLAlchemy и сельдерея. Я много искал и пробовал разные подходы, но ничего не получалось. Либо я пропустил контекст приложения, либо не могу запустить workers, либо есть какие-то другие проблемы. Структура очень общая, так что я могу построить более крупное приложение. Я использую: Flask 0.10.1, SQLAlchemy 1.0, Celery 3.1.13, моя текущая настройка следующее: App/__init__.py #Empty App/config.py import os base ...

Сельдерей задачи не бросая исключение в тестах Django

У меня есть пара заданий на сельдерей, которые включены в мои тесты Django. К сожалению, исключения не создаются, когда задачи вызываются через .delay () . Я устанавливаю CELERY_ALWAYS_EAGER в True. Tasks.py import celeryapp as app @app.task() def exception_task(): print 'CELERY_ALWAYS_EAGER:', app.conf['CELERY_ALWAYS_EAGER'] raise Exception('foo') Tests.py def test_exception_in_task(self): from tasks import exception_task exception_task.delay() Вывод CELE ...

Удаление всех отложенных задач в celery / rabbitmq

Как я могу удалить все отложенные задачи, не зная task_id для каждой задачи? ...

Как вы единичный тест задачи сельдерея?

документация по сельдерею упоминает тестирование сельдерея в Django но не объясняет, как проверить задачу сельдерея, если вы не используете Django. Как ты это делаешь? ...

Как проверить состояние задачи в сельдерее?

Как проверить, выполняется ли задача в celery (в частности, я использую celery-django)? Я прочитал документацию, и я погуглил, но я не вижу вызова, как: my_example_task.state() == RUNNING мой прецедент заключается в том, что у меня есть внешний (java) сервис для транскодирования. Когда я отправляю документ для транскодирования, я хочу проверить, выполняется ли задача, которая запускает эту службу, а если нет, то (повторно)запустить ее. Я использую текущие стабильные версии-2.4, I верить. ...

Распределенные очереди задач (напр. Сельдерей) vs crontab скрипты

У меня возникли проблемы с пониманием цели "распределенных очередей задач". Например, в Python сельдерей библиотека. Я знаю, что в celery, структуре python, вы можете установить временные окна для выполнения функций. Однако это также можно легко сделать в linux crontab, направленном на скрипт python. и насколько я знаю, и показано из моих собственных django-celery webapps, сельдерей потребляет гораздо больше оперативной памяти, чем просто настройка raw список задач. Разница в несколько сотен ...

Как я могу запустить периодическую задачу сельдерея из оболочки вручную?

Я использую сельдерей и Джанго-сельдерей. Я определил периодическую задачу, которую я хотел бы проверить. Можно ли запустить периодическую задачу из оболочки вручную, чтобы я мог просматривать вывод консоли? ...