Я хочу создать периодическую задачу для сельдерея, используя интерфейс администратора django-celery . У меня настроена задача, которая отлично работает при вызове вручную или по сценарию. Он просто не работает через celerybeat . Согласно журналам...

Мне удалось развернуть тестовое приложение, используя пирамиду с pserve и запустив pceleryd (я просто отправляю электронное письмо без блокировки во время его отправки). Но есть один момент, который я не понимаю: я хочу запустить свое приложение с...

У меня есть структура папок моего проекта api -- __init__.py --jobs/ -- __init__.py -- celery.py -- celeyconfig.py -- tasks.py --api_helpers/ --views/ tasks есть задача под названием...

У меня есть приложение django, для которого я использую задачи сельдерея для выполнения некоторой обработки csv в фоновом режиме, поэтому я установил rabbitmq-server как sudo apt-get install rabbitmq-server , с помощью этой команды сервер rabbitmq...

Мне нужно направить все задачи определенного экземпляра сайта django в определенную очередь. Моя настройка выглядит следующим образом: несколько веб-серверов, на которых запущен проект Django (1.7) один сервер с работниками сельдерея (3.1.7)...

У меня есть довольно сложный рабочий процесс (который строится динамически), который выглядит примерно так: workflow= chain( signature('workflow.tasks.start_workflow', kwargs= {}), chord( [ signature('workflow.tasks.group_task',...

Я следую всем инструкциям документов Celery. Сначала я следую этой ссылке , чтобы создать производственный процесс, и вот мой код приложения. 1-test_celery/celery.py:- from __future__ import absolute_import import os from celery import...

Я запускаю celery worker в качестве демона systemd , который обслуживает множество долго работающих агентов. Когда я перезапускаю рабочего, все агенты зависают и перестают запускать новые задачи в ожидании ожидающих выполнения. Перезапуск...