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

Что я могу сделать, если сельдерей забывает о задачах на (по-видимому) случайной основе?
У меня есть фляжное приложение с sqlalchemy и рабочим сельдереем. Я использую Redis в качестве своего брокера. Каждый раз, когда кто-то отправляет новое сообщение в беседе, запускается рабочий процесс, который должен отправлять уведомления всем...
272 просмотров
redis celery celery-task
schedule 14.11.2022
Прозрачная передача контекста веб-запроса задаче celery
У меня есть многопользовательская установка, в которой я хотел бы передать определенную информацию о клиенте, в частности request.host , в задачу celery, где в идеале она должна быть доступна в глобальной переменной. Есть ли способ настроить это...
1193 просмотров
flask celery celery-task flask-extensions
schedule 16.12.2023
Аргументы ошибки Celery Result должны быть списком или кортежем
Я запускаю веб-сайт Django и только что запустил Celery, но получаю запутанные ошибки. Вот как устроен код. В тестах.py: from tasks import * from celery.result import AsyncResult project = Project.objects.create() # initalize various...
5636 просмотров
python django celery celery-task celeryd
schedule 05.09.2023
Обмен сообщениями с комбу/сельдереем
У меня есть простое приложение, которое отправляет и получает сообщения, комбу и использует сельдерей для отправки сообщения. Комбу, я могу правильно принять сообщение. когда я посылаю «Привет», комбу получает «Привет». Но когда я добавил задачу,...
2884 просмотров
python celery celery-task kombu
schedule 17.04.2024
Сельдерей обрабатывает именованный аргумент
У меня есть такая задача сельдерея @app.task(bind=True,max_retries=3, default_retry_delay=1 * 60) def doTargetprefilter(self,*args,**kwargs ): Я называю это как args = [None,sourcedns, targetdnlist] kwargs= {'workername':workername,}...
1445 просмотров
python-3.x celery celery-task
schedule 14.02.2023
Как работает сельдерей?
Недавно я начал работать над распределенными вычислениями для увеличения скорости вычислений. Я выбрал Celery . Однако я не очень хорошо знаком с некоторыми терминами. Итак, у меня есть несколько связанных вопросов. Из документов по Celery :...
6257 просмотров
celery multiprocessing celery-task worker broker
schedule 06.06.2022
Celery отправляет почту для каждой неудачной задачи
Я использую сельдерей в своем приложении django, и у меня есть цветок сельдерея, чтобы отслеживать задачи сельдерея. У меня есть задачи настройки, когда электронные письма отправляются пользователю, когда он регистрирует/отправляет/события FP и т.д....
2497 просмотров
python django celery-task django-celery
schedule 20.11.2023
Безопасно ли использовать идентификаторы задач Celery в HTTP-запросах?
Я начинаю использовать Celery в веб-приложении на основе Flask для запуска асинхронных задач на стороне сервера. Несколько ресурсов получают подресурс '/action', которому пользователь/клиент может отправить POST, включая JSON-тело, указывающее...
175 просмотров
celery celery-task
schedule 29.12.2022
планирование задачи на несколько таймингов (с разными параметрами) с использованием сельдерея, но задача запускается только один раз (со случайными параметрами)
Чего я пытаюсь достичь. Напишите планировщик, который использует базу данных для планирования аналогичных задач в разное время. Так же, как я использую сельдерей, приведенный ниже фрагмент кода даст представление try: reader =...
557 просмотров
python-3.x celery scheduler celery-task celerybeat
schedule 23.01.2024
Локальный файл конфигурации демона сельдерея без django
Я новичок в сельдерее. Я создаю проект в соответствии с инструкциями, предоставленными документами celery4.1. Ниже представлена ​​​​папка и файлы моего проекта: mycelery | test_celery |...
1076 просмотров
python-2.7 celery celery-task celerybeat celeryd
schedule 15.06.2022
Django celery и celery-beat ошибка скрипта демонизации
Я собираюсь установить периодические задачи с сельдереем, для чего я пытаюсь демонизировать процесс сельдерея django на тестовом сервере с помощью скрипта (ссылка на официальный сайт): Сценарий инициализации: сельдерей Итак, это мой файл...
1015 просмотров
django celery celery-task celerybeat celeryd
schedule 24.02.2023
Установка атрибутов задачи Celery (например, time_limit и soft_time_limit) не работает
Судя по этой ветке, проблема решена, но похоже, что это не так. Установка ограничения времени для конкретной задачи с сельдереем Моя текущая версия Celery — 3.1.18 (Cipater). Я пытаюсь перезаписать настройки задачи по умолчанию. Цель состоит...
1080 просмотров
celery celery-task
schedule 26.05.2023
Как связать приложение сельдерея с классом Task?
Я хочу переопределить класс Task Celery. Я мог бы переопределить методы on_success и on_failure, но метод run для меня не так прост. Я попытался использовать метод bind. Мой код выглядит следующим образом: class MyTask(Task): def...
1682 просмотров
python celery celery-task
schedule 28.07.2022
Сеть сельдерея - Последнее задание никогда не называется
Цепочка последовательности (группа (задачи), final_sum.s()) не предоставляет аргументов для второй задачи final_sum.s() во внешней цепочке, которая не выполняется, даже если все остальное выполнено успешно. def function_task(): tasks1 = [] for i...
163 просмотров
celery celery-task
schedule 05.04.2022
Возможное состояние гонки между сигналом Django post_save и задачей celery
В приложении django 2.0 у меня есть модель с именем Document, которая загружает и сохраняет изображение в файловую систему. Эта часть работает. Я выполняю распознавание лиц на изображении, используя https://github.com/ageitgey/face_recognition в...
970 просмотров
django celery django-models celery-task
schedule 13.08.2022
Celery Принимает больше задач, чем параллелизм рабочих
Я выполняю несколько длительных задач в выделенной очереди. Так что краткосрочных задач не бывает. В настоящее время, когда я запускаю несколько задач в одной очереди, новые задачи отправляются работнику, который уже заполнен, т.е. нет задач =...
653 просмотров
airflow airflow-scheduler celery celery-task
schedule 06.12.2023
Поведение холста сельдерея различается в асинхронном и нетерпеливом режимах
Существуют некоторые расхождения в том, как холст Celery работает в асинхронном и нетерпеливом режимах. Я заметил, что группа, за которой следует цепочка в динамической задаче, которая заменяет себя, не отправляет результаты следующей в цепочке....
161 просмотров
celery celery-task celery-canvas
schedule 10.04.2024
Как исправить эту ошибку при запуске задачи сельдерея
Когда я пытаюсь запустить этот код, он выдает ошибку, я хочу запустить task_number_one и print_test как периодическую задачу, но она выдает одну и ту же ошибку для обоих. from celery.task import periodic_task from celery.schedules import crontab...
283 просмотров
python django celery celery-task django-celery
schedule 21.02.2022
Celery + SQS получает одну и ту же задачу дважды с одним и тем же идентификатором задачи в одно и то же время
используя celery с SQS в приложении flask , но celery получает одну и ту же задачу дважды с одним и тем же идентификатором задачи в одно и то же время , запускает worker таким образом, celery worker -A app.jobs.run -l info...
294 просмотров
flask amazon-sqs celery celery-task
schedule 26.12.2022
как вернуть представление django из задачи сельдерея?
Мне нужно вернуть форму из задачи django celery. Моя задача вызывается из следующего представления django: class MyView(CreateView): model = MyModel form_class = MyForm success_url = '/create/form' def form_valid(self, form):...
105 просмотров
django celery-task django-celery
schedule 02.10.2023