Вопросы по теме 'celery-task'

Проверьте, обрабатывается ли задача сельдерея.
Как я могу проверить, обрабатывается ли задача (task_id) в celery ? У меня есть следующий сценарий: Запустите задачу в представлении Django Сохраните BaseAsyncResult в сеансе Завершите работу демона сельдерея (жестко), чтобы задача больше...
4300 просмотров
python django celery celery-task
schedule 07.03.2023
В сельдерее, какой смысл в том, чтобы несколько рабочих обрабатывали одну и ту же очередь?
В документации для celeryd-multi мы находим этот пример: # Advanced example starting 10 workers in the background: # * Three of the workers processes the images and video queue # * Two of the workers processes the data queue with loglevel...
6420 просмотров
celery task-queue celery-task celeryd
schedule 28.12.2022
Совместное использование сеанса базы данных Pyramid с задачей Celery
Каков наилучший способ разделить сеанс SQLAlchemy между моим приложением Pyramid и задачами Celery, при этом только один раз создавая экземпляр ядра базы данных? Я посмотрел на этот ответ здесь , однако я не хочу создавать другой движок ( это также...
416 просмотров
python celery celery-task pyramid
schedule 01.05.2023
Ошибка Celery Worker: ImportError нет модуля с именем celery
Я получаю сообщение об ошибке импорта, когда пытаюсь запустить своего сельдерея. Я не уверен, в чем проблема. Любая помощь будет высоко оценен. Мой проект: email/__init__.py /celery.py Я пытаюсь запустить приложение, вызвав:...
57328 просмотров
python flask celery celery-task
schedule 10.08.2022
Как загружать объекты в память и делиться ими между различными исполнениями Celery worker?
Я настроил celery + rabbitmq на машине с 3 кластерами. Я также создал задачу, которая генерирует регулярное выражение на основе данных из файла и использует эту информацию для анализа текста. Тем не менее, я хотел бы, чтобы процесс чтения файла...
776 просмотров
celery celery-task django-celery
schedule 24.02.2024
создание подкласса задачи Celery для миксина `ClassTask`
Предваряя мой вопрос тем фактом, что я новичок в Celery, и на это (1) мог быть дан ответ где-то еще (если это так, я не смог найти ответ) или (2) может быть лучший способ достичь моей цели чем то, о чем я прямо спрашиваю. Кроме того, я знаю о...
572 просмотров
python celery celery-task
schedule 20.05.2024
Эффективные повторяющиеся задачи в сельдерее?
Каждый день у меня ~250 000 повторяющихся задач; примерно пятая часть из них может обновляться с разными запланированными датами каждый день. Можно ли это сделать эффективно в Celery? - Меня беспокоит это из beat.py сельдерея. : def...
957 просмотров
python celery celery-task celerybeat recurring-events
schedule 11.01.2023
crontab не работает с мультистартом сельдерея
Я пытаюсь заставить Celery работать некоторое время. Все мои crontabs работают нормально, когда я проверяю их синхронно sudo celery -A testdjango worker --loglevel=DEBUG --beat но когда я сделаю celery multi start -A testdjango w1 -l...
2586 просмотров
django celery celery-task
schedule 24.07.2022
Получить имя работника сельдерея из задачи сельдерея?
Я хотел бы, чтобы задача сельдерея могла получить имя выполняющего ее работника для целей ведения журнала. Мне нужно справиться с этим из задачи, а не напрямую запрашивать брокера. Есть ли способ сделать это? Я использую сельдерей с RabbitMQ, если...
8181 просмотров
python celery celery-task
schedule 16.06.2022
Состояние задачи Celery всегда в ожидании
Я новичок в сельдерее и джанго в целом, поэтому, пожалуйста, извините меня за недостаток знаний. Я пытаюсь запустить тест, чтобы выполнить некоторые расчеты, и дождаться завершения теста, чтобы убедиться, что он выполнен для правильных ответов....
19928 просмотров
python django celery celery-task django-celery
schedule 04.05.2022
Электронная почта Django Celery, сельдерей не работает
Я работаю над сельдереем django для отправки электронного письма о регистрации, но сельдерей работает неправильно. моя ошибка в сельдерее [2014-09-10 19:11:44,349: WARNING/MainProcess] celery@Jeet-PC ready. [2014-09-10 19:13:38,586:...
741 просмотров
python django celery-task django-celery
schedule 20.07.2022
Выполнение задачи Django celery
У меня есть 3 задачи в файле tasks.py, когда демон работает, выполняется только одна задача. Остальные два отображаются в режиме отладки, но не выполняются. celery worker --concurrency=1 Нужны ли какие-то изменения? Редактировать :...
516 просмотров
django celery-task
schedule 05.11.2022
Celery снова и снова выполняет давно выполняемые задачи.
У меня есть очередь python celery-redis, обрабатывающая загрузки и выгрузки на гигабайты данных за раз. Некоторые загрузки занимают до нескольких часов. Однако как только такая задача завершается, я становлюсь свидетелем этого странного поведения...
1962 просмотров
python celery celery-task
schedule 19.12.2022
проблемы с python logging.getLogger(__name__)
Я пытаюсь получить журналы из библиотеки, которую использую (PyAPN). Это, конечно, не работает из коробки. Я просмотрел код библиотеки, чтобы увидеть, что они используют для регистратора, и они используют метод logging.getLogger(). Существующий...
4740 просмотров
python flask logging uwsgi celery-task
schedule 08.06.2024
Celery KeyError при обертывании функции app.task импортированным декоратором; ошибки только с импортом
Учитывая компоновку: background \ tasks \ __init__.py generic.py helpers.py __init__.py _server.py config.py router.py server.py И запуск _server.py с celery -A background._server worker...
873 просмотров
python celery celery-task celeryd
schedule 30.04.2022
Как создать общий счетчик в Celery?
Есть ли способ иметь общий счетчик (общий для рабочих) в Celery? Я также открыт для других идей о том, как решить мою проблему, но хотел бы придерживаться Celery. Вот моя проблема: У меня есть задача, которая зависит от переданного ей индекса....
380 просмотров
python celery celery-task
schedule 10.12.2022
Python Celery: обновление состояния AsyncResult
После успешного выполнения родительской задачи, в зависимости от результатов некоторых дочерних задач, я хочу обновить состояние задачи. Однако: 1/ я не могу найти способ получить фактический экземпляр задачи на основе его идентификатора, только...
1166 просмотров
python celery celery-task
schedule 04.10.2023
Как получить доступ к форме с задачами сельдерея?
Я пытаюсь перевернуть логический флаг для определенных типов объектов в моей базе данных, используя sqlalchemy + celery beats. Но как мне получить доступ к моей форме из файла tasks.py? from models import Book from celery.decorators import...
2162 просмотров
flask flask-sqlalchemy celery celery-task celerybeat
schedule 05.12.2022
Правильный способ асинхронного выполнения задачи в Django через Celery
У меня есть приложение Django, которое имитирует Instagram, в котором пользователи загружают фотографии или мемы, а затем их поклонники получают уведомление об указанной фотографии. В настоящее время, чтобы отправлять уведомления, как только...
929 просмотров
python django celery celery-task django-celery
schedule 02.02.2023
Flask Celery update_state из другой функции
Я хотел бы обновить состояние моей задачи Celery из другой функции. Вот что у меня есть сейчас: Маршрут @app.route('/my-long-function', methods=['POST']) def my_long_function(): param1 = request.form['param1'] param2 =...
1232 просмотров
flask celery celery-task
schedule 01.12.2022