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

NoneCeleryd is the common name of a Celery worker node, running as a daemon.
1 ответ

Celery/Redis task expiration

Я использую Celery с супервизором, управляющим работниками, и Redis в качестве посредника, и у меня возникла проблема с зависанием работника Celery, который не может обрабатывать больше задач и приводит к тому, что очередь его задач в Redis заполняе…
27 фев '18 в 02:18
0 ответов

Каково оптимальное количество работников сельдерея на ядро?

В документах по сельдерею не так много информации об оптимальном количестве рабочих, которые можно использовать на машину. Я считаю, что по умолчанию сельдерей создает по одному рабочему на ядро ​​машины. Из экспериментов я знаю, что на одноядерном …
14 окт '14 в 20:07
1 ответ

Команда 'celeryd' не известна при использовании ckanext-archiver

Я использую CKAN в качестве портала открытых данных и устанавливаю расширение Archiver, следуя инструкциям по адресу https://github.com/ckan/ckanext-archiver. Я установил сельдерей, как показано на рисунке: Successfully installed celery kombu kombu-…
10 июн '14 в 09:16
1 ответ

Celeryd запускает слишком много процессов

Как вы гарантируете, что celeryd работает только как один процесс? Когда я бегу manage.py celeryd --concurrency=1 а потом ps aux | grep celery Я вижу 3 запущенных экземпляра: www-data 8609 0.0 0.0 20744 1572 ? S 13:42 0:00 python manage.py celeryd -…
12 июн '13 в 18:48
1 ответ

Демон celery: не найден / ошибка celery d в файле конфигурации

Я демонизировал сельдерей на Ubuntu, следуя руководству пользователя и этому вопросу на SO. Коротко говоря, Загрузите init-скрипт celeryd из репозитория clery github. Сохраните файл конфигурации из руководства пользователя в виде celeryd.conf (чтобы…
30 дек '16 в 18:16
0 ответов

Django-сельдерей с django2.0 в работе с супервизором продолжает посылать задачи, но не выполняет ни одной

Это последние 100 строк моего журнала сельдерея Django, кажется, что ни одна работа не выполняется. [2018-06-26 10:42:57,286: INFO/Beat] Writing entries (1)... [2018-06-26 10:42:57,388: INFO/Beat] Scheduler: Sending due task save_fullstory (get_arti…
26 июн '18 в 12:41
1 ответ

Начать сельдерей с командой sudo

Я работаю с Celery и пытаюсь начать с sudo. sudo celery multi start worker --app=app.celery --loglevel=info --concurrency=1 Мне нужно запустить команду с sudo, однако, когда я это делаю, я получаю ошибку разрешения. Как я могу запустить Celery с пом…
0 ответов

Сельдерей бесконечная задача, которая слушает очередь

У меня есть задача с сельдереем, которая должна выполняться в бесконечном цикле, прослушивая несколько очередей (не связанных с внутренностями из сельдерея) в RabbitMQ. Когда сообщение извлекается из очереди, эта длительная задача отправляет это соо…
14 ноя '16 в 14:53
7 ответов

Как перезапустить Celery изящно, не затягивая задачи

Мы используем Celery с нашим веб-приложением Django для управления автономными задачами; некоторые из этих задач могут выполняться до 120 секунд. Когда бы мы ни делали какие-либо модификации кода, нам нужно перезапускать Celery, чтобы он перезагрузи…
10 мар '12 в 00:13
1 ответ

Работник не может получить новую вставку данных в mysql в задании из фляги сельдерея

У меня есть три сервера, на которых запущена моя программа, и на каждом сервере есть восемь рабочих из сельдерея, чтобы получить задачу от Redis. То есть задача сельдерея каждого сервера может быть выполнена другим сервером. На каждом сервере:зафикс…
04 ноя '16 в 14:04
1 ответ

Проблемы с остановкой сельдерея

Я работаю с celeryd как с демоном, но иногда у меня возникают проблемы с его грацией. Когда я отправляю сигнал TERM и в очереди есть элементы (в этом случае service celeryd stop) celeryd перестанет работать и закроет все рабочие процессы. Однако род…
18 фев '11 в 19:31
1 ответ

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

У меня есть проект Django с сельдереем. Я вижу проблему, когда некоторые работники получают задание с одним и тем же идентификатором более одного раза. Вот фрагмент журнала: 9238 [2015-07-03 10:25:03,310: INFO/MainProcess] Task ssrweb.execution.task…
03 июл '15 в 14:43
1 ответ

Запустить Celery на том же сервере, что и django?

Я запускаю свое приложение Django в среде Elastic Beanstalk с балансировкой нагрузки. Я хочу добавить процесс Celery daemon для следующих действий: Загрузите файлы на S3 в фоновом режиме и отправьте успешный ответ на мое приложение для Android Отпра…
2 ответа

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

В сельдерее я хочу получить статус задачи для всех задач для конкретного имени задачи. Для этого попробовал приведенный ниже код. import celery.events.state # Celery status instance. stat = celery.events.state.State() # task_by_type will return list…
22 июл '13 в 09:02
2 ответа

Как устранить неполадку тайм-аута выхода celeryd при работе на Heroku (ошибка R12)?

Я бегу с сельдереем на Heroku Dyno. Когда я выключаю его, и он ранее обработал (даже выполнил) хотя бы одну задачу, он не закрывается должным образом, и я получаю ошибку R12 (тайм-аут выхода) от Heroku. Вот как я бегу из сельдерея из моего Procfile …
07 сен '12 в 13:07
1 ответ

/init.d/function + версия Python

Я пытаюсь демонизировать сельдерей и сельдерея. Я скачал файлы celeryd и celeybeat с github и поместил их в /etc/init.d/ (сельдерей и сельдерея) с соответствующими файлами конфигурации под /etc/default/, Моя проблема в том, что когда я запускаю эти …
10 июн '13 в 23:19
2 ответа

Сельдерей не может найти работника

Я использую сельдерей с такой конфигурацией default_exchange = Exchange('default', type='direct') latest_exchange = Exchange('latest', type='direct') shared_celery_config = { 'BROKER_URL': 'redis://localhost:6379/0', 'CELERY_RESULT_BACKEND': 'redis:…
08 сен '16 в 09:45
0 ответов

Перезапустит ли celeryd текущие задачи?

Если у меня есть два рабочих процесса, выполняющих длительные операции. Если я использую /etc/init.d/celeryd restart как в официальном документе перезапустить их, когда они находятся в процессе обработки задач, что происходит потом? Будут ли они жда…
21 июл '17 в 07:26
2 ответа

Производственная установка для сельдерея

Как я могу настроить Celery на производственном сервере, используя aws или digitalocean и брокер как redis или rabbitmq. Пожалуйста, расскажите подробнее о том, как мы можем обеспечить отказоустойчивость соединения, когда посредник не работает.
02 янв '18 в 05:10
1 ответ

Проблемы совместного использования переменных в сельдерее

Я использую Python и сельдерей в проекте. В проекте у меня есть два файла: celeryconfig.py BROKER_URL = "amqp://guest:guest@localhost:5672//" CELERY_RESULT_BACKEND = "amqp" CELERY_IMPORTS = ("example",) CELERYD_CONCURRENCY = 2 и example.py from cele…