Описание тега celery

Вопросы с тегом
Celery - это распределенная очередь задач, написанная на Python.
0 ответов

Запустить сценарий оболочки как подпроцесс Supervisord?

У меня есть приложение Django 1.6.2, которое использует Celery 3.1.7 для асинхронных задач. Я начинаю своих работников из сельдерея с помощью Supervisor. Пока что все работает хорошо, за исключением случаев, когда я перезагружаю свой сервер Debian 7…
18 май '15 в 20:14
0 ответов

Сельдерей, как изменить имя работника, чтобы избежать использования [в] в своем имени

Я запустил сельдерей с этой командной строкой python3 -m celery worker --task-events --loglevel=INFO -Q fast_tasks --autoscale=50,10 -A apcli --logfile=syslog --pidfile=/var/run/celery/fast_tasks.pid --hostname=%h Эта команда создает имя рабочего: f…
28 май '19 в 11:00
1 ответ

Celery Daemon получает незарегистрированные задания

Я установил Celery для своего проекта Django, следуя тому, что написано в официальном руководстве. И он работает нормально, когда я запускаю celery в командной строке, я вижу, как он получает задачи и выполняет их. Но как только все заработало, я ре…
13 авг '12 в 08:12
1 ответ

Celery и RabbitMQ - Инструменты для мониторинга и сигнализации тревоги

Я думаю, что мы достигли предела юзабилити celery events а также celery fllower, Есть ли хороший инструмент для мониторинга статуса Celery под RabbitMQ? В частности, я хотел бы что-то поднять тревогу, когда: Мои очереди копируются Потребители регист…
07 июн '13 в 23:31
0 ответов

OSError: [Errno 38] Функция не реализована - реализация Django Celery

Я установил django-celery и попытался запустить рабочий сервер, но я получил OSError, что функция не реализована. Я использую CentOS версии 5.4 (Final) на VPS: . broker -> amqp://guest@localhost:5672/ . queues -> . celery -> exchange:celery…
23 июл '10 в 16:41
1 ответ

Supervisord в качестве службы Windows на Cygwin

Я пытаюсь запустить Celery в качестве службы Windows, используя Supervisord. Я следовал конфигурации, изложенной на сайте Celery и здесь. Я создал виртуальную среду для запуска супервизора через Cygwin. Я выделил строки, которые я считаю наиболее ва…
01 авг '14 в 23:03
3 ответа

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

У меня есть сервер Python на основе Django и сельдерея. Каждый раз, когда компьютер перезагружается, запускается apache2, так что мой сервер работает, НО мне приходится перезапускать celery вручную (перейдя в каталог моего проекта и выполнив "python…
18 фев '10 в 21:22
1 ответ

Ошибка базы данных между Oracle и Django с сельдереем

У меня проблемы с тем, что кажется самым последним шагом в развертывании проекта Django-Celery-RabbitMQ. После запуска сервисов celery, httpd и rabbitmq-server через systemd, когда я запускаю задачу в Django, я вижу сообщение Received task: smartale…
09 сен '16 в 15:33
1 ответ

Задачи сельдерея из одного домена отображаются в администраторе django другого домена, расположенном в том же окне

У меня довольно забавная проблема, которую мне не удалось найти в другом месте. У меня есть 2 проекта django-celery, работающие с redis на 2 разных доменах, но, очевидно, размещенные на одной коробке. У меня нет доступа к sudo, поэтому я не использу…
30 июл '13 в 13:20
2 ответа

Сельдерей с Upstart - процессы умирают неожиданно

Когда я запускаю Celery с Upstart, через некоторое время дочерние процессы или основные процессы умирают без следа. Скрипт Upstart, который я использую (/etc/init/celery): description "celery" start on runlevel [2345] stop on runlevel [!2345] kill t…
25 сен '13 в 16:42
0 ответов

Процессы Zombie Firefox и Geckodriver после запуска запланированного скребка (на основе безголового селена)

У меня есть 10 заданий, которые представляют собой скребки на основе селена, которые используют сельдерей для планирования и запуска с Redis в качестве брокера. Selenium использует geckodriver для подключения и использует Firefox (безголовый режим) …
20 мар '19 в 18:30
2 ответа

kill -HUP не работает с демоном сельдерея

Итак, у меня есть сценарий оболочки, который демонизирует сельдерей и создает группу рабочих, работающих как демон. Я хотел бы иметь возможность перезапустить задачу сельдерея, когда основной источник изменяется с --autoreload опция не работает. Сог…
21 янв '13 в 23:25
0 ответов

Supervisor запускает / останавливает / перезапуска не работает, как ожидалось

Я использую супервизор для управления сельдереем, и из-за случайных требований проекта требуется добавить переменные среды. Я установил их в разделе supervisor [environment] файла.conf, но просто используя service supervisor stop service supervisor …
10 июл '15 в 00:30
2 ответа

Какой правильный синтаксис для запуска cron каждые 48 часов?

Будет ли это работать правильно? CELERYBEAT_SCHEDULE = { 'task-number-one': { 'task': 'project.users.tasks.send_something', 'schedule': crontab(minute='*/2880'), } }
05 дек '17 в 14:48
1 ответ

Подход к автоматическому масштабированию серверов сельдерея на основе размера очереди посредника (redis)

Я работаю над проектом, который требует развертывания новых серверов сельдерея, если очередь посредника (redis) постоянно превышает заданный пороговый размер, и уничтожает новые блоки, когда размер очереди уменьшается. У меня есть сценарии, чтобы по…
12 апр '13 в 19:32
3 ответа

Запуск нескольких рабочих с использованием сельдерея

Мне нужно читать из Rabbitmq и параллельно выполнять задачу, используя Celery в одной системе. [2014-12-30 15:54:22,374: INFO/Worker-1] ... [2014-12-30 15:54:23,401: INFO/Worker-1] ... [2014-12-30 15:54:30,878: INFO/Worker-1] ... [2014-12-30 15:54:3…
30 дек '14 в 11:41
0 ответов

Проблемы пересмотра VPN-туннеля

У меня есть приложение, работающее поверх Celery с Redis в качестве брокера. Redis размещен в нашем центре обработки данных, но рабочие размещены на отдельной линии. Мы настроили двустороннюю связь между серверами, используя vpn-туннель. Проблема в …
03 фев '15 в 08:37
1 ответ

Есть ли способ использовать длину очереди RabbitMQ, используемой Celery, для запуска экземпляра в группе автомасштабирования?

Есть ли у Celery способ генерировать события, когда длина очереди превышает пороговое значение? Я хочу использовать это событие для запуска экземпляра EC2. У нас есть две очереди для двух разных задач в сельдерее. В одной из этих очередей есть задач…
17 июл '15 в 14:20
0 ответов

Как просмотреть ожидающие сообщения в администраторе RabbitMQ?

Как вы просматриваете ожидающие / помещенные в очередь сообщения в администраторе RabbitMQ? У меня запущен инструмент администратора RabbitMQ, и на странице обзора показано, что готово более 4000 сообщений. Это также показывает, что есть более 90 по…
19 июл '17 в 18:44
1 ответ

Удалить потребителя перед началом развертывания из очереди RabbitMQ

У нас есть настройка Celery Worker с настройкой 8 узлов. Это создает 8 очередей в RabbitMQ. Когда мы начинаем развертывать новые изменения, последний шаг в ANSIBLE Playbook - перезапуск Celery. Перезапуск сельдерея должен завершить работу каждого уз…
18 июл '18 в 11:54