celery
Я запускаю некоторые длинные задачи, где мне нужно убедиться, что поставленные в очередь задачи выполняются в порядке приема. Что я обнаружил в своих первых тестах, так это то, что когда я достигаю максимального количества рабочих (CELERYD_CONCURRENCY), следующие задачи, которые отправляются, помещаются в оч...
У меня есть два отдельных процесса celeryd, запущенных на моем сервере, управляемых supervisor. Они настроены на прослушивание отдельных очередей как таковые: [program:celeryd1] command=/path/to/celeryd --pool=solo --queues=queue1 ... [program:celeryd2] command=/path/to/celeryd --pool=solo --queues=queue2 ...
Попытка запустить supervisord (3.2.2) с помощью celery multi. Похоже, что супервайзер не может справиться с этим. Один работник сельдерея работает нормально. Это моя конфигурация супервайзера celery multi v3.1.20 (Cipater) > Starting nodes... > celery1@parzee-dev-app-sfo1: OK Stale pidfile exist...
Я пытаюсь придумать методику тестирования для наших Джанго-сельдерей. Я прочитал заметки в документация, но это не дало мне хорошего представления о том, что на самом деле делать. Я не беспокоюсь о тестировании задач в реальных демонах, просто функциональность мой код. В основном мне интересно: как мы мо...
Я читал документ и искал, но не могу найти прямой ответ: можно ли отменить уже выполненную задачу? (как и в задаче стартовал, занимает некоторое время, и на полпути его нужно отменить) Я нашел это из документа в сельдерей FAQ >>> result = add.apply_async(args=[2, 2], countdown=120) >>> r...
Я пытаюсь запустить пример из сельдерея документации. Я бегу: celeryd --loglevel=INFO /usr/local/lib/python2.7/dist-packages/celery/loaders/default.py:64: NotConfigured: No 'celeryconfig' module found! Please make sure it exists and is available to Python. "is available to Python." % (configname, ))) [201...
мне интересно, как настроить более конкретную систему ведения журнала. Все мои задачи используют logger = logging.getLogger(__name__) как модульный регистратор. Я хочу, чтобы сельдерей вошел в "celeryd.войти "и мои задачи в" задачи.журнал " но я понятия не имею, как заставить это работать. Используя CELER...
В настоящее время я работаю над проектом python, который требует реализации некоторых фоновых заданий (в основном для отправки электронной почты и обновления базы данных). Я использую Redis для брокера задач. Так что в этом пункте у меня есть два кандидата:сельдерей и RQ. Я имел некоторый опыт работы с этими ...
У меня есть задача с интенсивным ЦП сельдерея. Я хотел бы использовать всю вычислительную мощность (ядра) во многих экземплярах EC2, чтобы выполнить эту работу быстрее (параллельная распределенная задача сельдерея с многопроцессорной обработкой -Я думаю). условия резьбонарезной, многопроцессорная обработка,р...
Я работаю над проектом, который сканирует почтовый ящик пользователя gmail и предоставляет отчет. Я развернул его в heroku со следующими характеристиками: язык: Python 2.7 основа: Django 1.8 Планировщик заданий: сельдерей (Rabbitmq-bigwig на урл) теперь, когда heroku выполнить его сельдерей не дает мне...