Сельдерей бить с методом задачи не работает

Я пытаюсь запустить метод сельдерея на методической задаче и не могу заставить что-либо работать должным образом. Вот пример настройки: from celery.contrib.methods import task_method from celery import Celery, current_app celery=celery('tasks', ...

Сельдерей: как ограничить количество задач в очереди и прекратить кормление при заполнении?

Я очень новичок в сельдерее, и вот у меня есть вопрос:Предположим, у меня есть скрипт, который постоянно должен получать новые данные из БД и отправлять их р...

Запустите Scrapy Spider в сельдерее

Это больше не работаетAPI Scrapy изменился.Теперь в документации есть способ "Запустите Scrapy из сценария"но я получаю

График ритма сельдерея: выполнить задание мгновенно, когда начнется ритм сельдерея?

Запуск Scrapy Spiders в задаче сельдерея

У меня есть сайт Django, где скребок происходит, когда пользователь запрашивает его, и мой код запускает автономный скрипт Scrapy Spider в новом процессе. Ес...

Сельдерей: автоматическое обнаружение не находит модуль задач в приложении

У меня есть следующая установка со свежим установленным сельдереем и django 1.4: Settings.py: import djcelery djcelery.setup_loader() BROKER_HOST = 'localhost' BROKER_PORT = 5672 BROKER_USER = 'user' BROKER_PASSWORD = 'password' BROKER_VHOST ...

Сельдерей: застрял в бесконечно повторяющихся тайм-аутах (Тайм-аут в ожидании сообщения UP)

Я определил некоторые задачи с ограничением по времени 1200:

Python - Повторите неудачную задачу Celery из другой очереди.

Я публикую данные на веб-сервисе в Celery. Иногда данные не публикуются в веб-сервисе из-за отсутствия интернета, и задача повторяется бесконечно, пока не бу...

Модульное тестирование AsyncResult в сельдерее

Я пытаюсь проверить некоторые функции сельдерея в модульном тестировании Django, но всякий раз, когда я пытаюсь проверить AsyncResult, тесты действуют так, как будто они никогда не запускались. Я знаю, что этот код работает в реальной среде с ...

Задача Celery Group для использования на карте / сократить рабочий процесс

Могу ли я использовать сельдерейгруппа примитив как зонтичная задача на карте / сократить рабочий процесс? Или более конкретно: можно ли выполнять подзадачи...