Результаты поиска по запросу "celery"
Python SSL-соединение «EOF произошло с нарушением протокола»
Я использую задачу Django Celery для подключения к Facebook Graph API с запросами lib с помощью Gevent. Проблема, с которой я постоянно сталкиваюсь, заключается в том, что время от времени я получаю EOF, происходящее с нарушением протокола. Я ...
Запуск нескольких экземпляров сельдерея на одном сервере
Я хочу запустить два экземпляра сельдерея на одной машине. Один для версии моего приложения «А», другой для версии «Б». У меня есть два случая, которые я начинаю так: (env1)/home/me/firstapp$ celery -A app.tasks worker --config ...
celery + django - как записать состояние задачи в базу данных
Я запускаю Celery с Django и RabbitMQ и хочу видеть состояния задач в таблице базы данных. К сожалению, в таблицу djcelery_taskstate не записано никаких записей, и я не могу понять, почему. Мои настройки: CELERY_ENABLE_UTC = True BROKER_URL = ...
Лучший способ сопоставить сгенерированный список с задачей в сельдерее
Я ищу несколько советов о том, как лучше сопоставить список, созданный из задачи, с другой задачей в сельдерее. Допустим, у меня есть задача под названиемparse, который анализирует документ PDF и выводит список страниц. Затем каждая страница ...
Запуск задачи после завершения всех задач
Я пишу приложение, которое должно выполнять серию задач параллельно, а затем одну задачу с результатами всех выполненных задач: @celery.task def power(value, expo): return value ** expo @celery.task def amass(values): print str(values)Это очень ...
Распределенные очереди задач (например, Celery) против сценариев crontab
У меня проблемы с пониманием цели «распределенных очередей задач». Например, питонбиблиотека сельдерея [http://www.celeryproject.org/]. Я знаю, что в сельдерее, среде Python, вы можете установить временные окна для запуска функций. Тем не менее, ...
Проблемы сеанса SQLAlchemy с сельдереем
Я запланировал несколько повторяющихся задач с сельдереем для нашего веб-приложения. Само приложение построено с использованием веб-фреймворка пирамиды. Использование расширения zopetransaction для управления сеансом В сельдерее я использую ...
Сельдерей остановить исполнение цепи
У меня есть задача check_orders, которая выполняется периодически. Он создает группу задач, так что я могу определить, сколько времени заняло выполнение задач, и выполнить что-то, когда все они выполнены (это цель res.join [1] и grouped_subs). ...
Как я могу автоматически перезагрузить модули задач с помощью демона Celery?
Я использую Fabric для развертывания брокера Celery (работающего с RabbitMQ) и нескольких работников Celery сceleryd демонизируется черезsupervisor, Я не могу на всю жизнь понять, как перезагрузитьtasks.py Модуль за исключением перезагрузки ...
Сельдерей и SQLAlchemy - этот объект результата не возвращает строки. Было закрыто автоматически
У меня есть проект сельдерея, связанный с базами данных MySQL. Одна из таблиц определяется так: class MyQueues(Base): __tablename__ = 'accepted_queues' id = sa.Column(sa.Integer, primary_key=True) customer = sa.Column(sa.String(length=50), ...