Вопросы по теме 'celerybeat'

Как настроить и запустить celerybeat
Я только начинаю работать с сельдереем, пытаясь запустить периодическую задачу. Настроенный *rabbitmq** добавил celeryconfig.py. И добавил следующий код в tasks.py: from celery.decorators import periodic_task from datetime import timedelta...
9988 просмотров
schedule 22.07.2022

Celerybeat с ошибкой подключения Mongo
Я пытаюсь настроить очередь задач сельдерея с помощью celerybeat для периодических обновлений базы данных. Мой сервис celeryd работает отлично, но celerybeat продолжает выдавать мне Connection error: [Errno 111] : [2012-09-10 09:40:18,954:...
1738 просмотров
schedule 14.06.2023

celery beat не работает должным образом
когда я запускаю эту команду для удара сельдерея. [2013-06-27 02:17:05,936: INFO/MainProcess] Celerybeat: Запуск... [2013-06-27 02:17:05,937: INFO/MainProcess] Запись записей... [2013-06-27 02:17:08,711: INFO/MainProcess]...
10011 просмотров
schedule 23.07.2023

Django 1.6 + RabbitMQ 3.2.3 + Celery 3.1.9 — почему мой рабочий celery умирает с: WorkerLostError: Worker вышел преждевременно: сигнал 11 (SIGSEGV)
Кажется, это решает очень похожую проблему, но не дает мне достаточного понимания: https://github.com/celery/billiard/issues/101 Похоже, было бы неплохо попробовать базу данных, отличную от SQLite... У меня есть простая настройка сельдерея с моим...
1851 просмотров

Рабочий сельдерея, работающий из командной строки, но не как демон, в virtualenv
Системная информация Ubuntu 12.04 LTS Django 1.5.5 Python 2.7.3 Сельдерей 3.1.9 Я запускаю это на бродячей виртуальной машине (с марионеткой) и пытаюсь настроить сельдерей для запуска рабочего как демона, как описано в документации по...
1958 просмотров
schedule 17.05.2022

Celery Beat - почтовая пирамида
Итак, у меня есть простой код Python, который отлично работает в обычной оболочке Python: from pyramid_mailer.mailer import Mailer from pyramid_mailer.message import Message from pyramid_mailer.message import Attachment mailer = Mailer(...
456 просмотров
schedule 10.05.2022

Периодические задачи Celerybeat выполняются несколько раз, если они застряли за долго выполняющейся задачей
Я использую сельдерей 3.1.17 и Redis в качестве брокера версии 3.0.2 в моей программе django. Он работает на Ubuntu 14.04. В настройках я определил CELERYBEAT_SCHEDULE как: CELERYBEAT_SCHEDULE = { 'task1': { 'task':...
1002 просмотров

Запустите celery worker и celery beat как поток
Я использую сельдерей для выполнения некоторых задач, запускаемых по времени. Используя обычные методы командной строки, я легко могу генерировать задачи и выполнять их. Для этого мне нужно создать два демона, один для celery beat и другой для...
1355 просмотров
schedule 20.10.2022

Celery Beat: как определить периодические задачи, определенные как классы (задачи на основе классов)
До сих пор я работал только с задачами Celery, определенными как функции. Раньше я определял их периодичность в параметре CELERYBEAT_SCHEDULE . Как это: from datetime import timedelta CELERYBEAT_SCHEDULE = { 'add-every-30-seconds': {...
613 просмотров
schedule 12.11.2023

Как решить эту ошибку? RestartFreqExceeded: 5 в 1 с в django+celery+rabbitmq+mysql+redis
Итак, я использую django с сельдереем. rabbitmq является брокером. Redis - это кеш. mysql это БД. (все на локальном хосте) Я использую python2.7 и использую виртуальную среду на основе virtualenv. Я запускаю сервер Redis (локальный) на...
2370 просмотров

запускать задачи сельдерея в случайное время
мне нужно запустить несколько задач сельдерея в случайное время - каждый запуск должен быть в новое случайное время - при каждом запуске должно генерироваться случайное число. что я делал в прошлом: "my_task": { "task":...
1321 просмотров
schedule 16.05.2023

Разрешения Celery Django celerybeat.pid
Запуск Celery с Django на производственном сервере Debian под пользователем, который не может писать в директорию проекта, но при инициализации celery beat необходимо создать файл для хранения pid (celerybeat.pid). > File >...
1197 просмотров
schedule 23.08.2022

Периодическая задача Django celerybeat запускается только один раз
Я пытаюсь запланировать задачу, которая запускается каждые 10 минут, используя Django 1.9.8, Celery 4.0.2, RabbitMQ 2.1.4, Redis 2.10.5. Все они работают в контейнерах Docker в Linux (Fedora 25). Я пробовал много комбинаций вещей, которые я нашел в...
2127 просмотров
schedule 26.12.2022

Статус сельдерея застрял в статусе ожидания
Я нашел пример запуска сельдерея с mongodb в качестве бэкэнд-результата здесь original пример кода . В его примере у него есть CELERYBEAT_SCHEDULE с некоторыми параметрами для запуска каждую минуту, в моем случае я просто закомментировал этот код....
1115 просмотров

Правильная настройка django redis celery и celery beats
Я пытаюсь настроить django + celery + redis + celery_beats, но это вызывает у меня проблемы. Документация довольно проста, но когда я запускаю сервер django, redis, celery и celery beats, ничего не печатается и не регистрируется (все мои тестовые...
1738 просмотров
schedule 21.04.2022

Демон django celery работает: он не может создать файл pid
Я не могу запустить службу mi celeryd и celerybeat, я использовал тот же код в другой среде (настроил все с самого начала), но здесь не работает. Я думаю, что это было по разрешениям, но я не мог его запустить. пожалуйста, помогите мне. это мой...
1288 просмотров

Проблема с django-celery, не работающим в определенное время
У меня проблемы с тем, что django-celery не запускается в указанное время, но он всегда запускается каждую минуту. Ниже я вставил tasks.py, settings.py и celery.py. Я тестировал с djcelery, а также с сельдереем. Я использую сельдерейный бит....
462 просмотров
schedule 30.08.2022

Как мы выполнили стоп-задачи в celery Period_Task?
Отзыв задачи на @periodic_task отправляет Discarding revoked tasks & Due task to workers. скриншот celery-workers [2018-09-17 12:23:50,864: INFO/MainProcess] Received task: cimexapp.tasks.add[xxxxxxx] [2018-09-17 12:23:50,864:...
2647 просмотров

Задачи Celerybeat получают ту же информацию, даже если она изменилась. (возможно кеширование) Как я могу отключить это
У меня есть задача, настроенная в ритмах сельдерея, которая запускается каждые 2 минуты. Он использует цикл if, основанный на существовании объекта БД self.dbObject = Patch.find_by_status('READY') , я включаю работника, и код работает нормально. Но...
99 просмотров
schedule 07.03.2024

Как получить идентификатор задачи из сельдерея в случае запланированных задач (бит)
Чтобы получить доступ к информации о задаче с сельдереем, мне нужен task_id. Когда задача сельдерея запускается вручную, я могу легко получить идентификатор этой задачи с помощью task.id (и записать его в БД или сделать что-то еще). Если я использую...
1081 просмотров
schedule 04.10.2022