Вопросы с меткой [celery]

Celery — это асинхронная распределенная очередь задач, построенная на передаче сообщений. Celery ориентирован на работу в режиме реального времени, но также поддерживает планирование.

Фильтрация
Сортировка
Метки
0 голосов
0 ответов
10 показов

Ошибка celery.beat.SchedulingError: Couldn't apply scheduled task ...: send_course_update_email() missing 1 required positional argument: 'course_id'

У меня есть задача в Django rest framework, она выглядит следующим образом: @shared_task(name='send_message_subscriptions') def send_course_update_email(course_id): # Список подписчиков на ...
Иван's user avatar
0 голосов
0 ответов
25 показов

Как интегрировать отправку OTP с Celery в проект?

Вот мой viewset и serialsers. Я хочу интегрировать отправку OTP во время авторизации пользователя. Чтобы пройти успешную авторизацию, нужно ввести 6-ти значный OTP код. Как мне лучше это сделать? ...
Danil Mustafin's user avatar
0 голосов
0 ответов
27 показов

Не работает вызов функции через Celery

Хочу написать небольшую апишку на flask, которая при переходе на /get_domain_users будет вызывать асинхронную функцию при помощи Celery, чтобы получить данные из бд и закинуть в json, который ...
Иван Чумаков's user avatar
1 голос
0 ответов
31 показ

Celery не находит модели при выполнении задачи

Пишу Api для телефонной рассылки, мой код принимает заявки на рассылку и когда настает время начала рассылки он отправляет запрос на внешнюю Api, которая в свою очередь отправляет сами сообщения. Если ...
Юрий's user avatar
0 голосов
0 ответов
18 показов

ResultMissing при выполнении задачи Dramatiq

Для своего проекта (бэкенд интернет-магазина на Django) я реализовал имитацию оплаты заказа. Для практики решил использовать Dramatiq, чтобы потренироваться с асинхронным выполнением задач. Вот мой ...
EtherealWanderer's user avatar
1 голос
1 ответ
170 показов

Django+Celery не выполняется task

Я хочу сделал так что при регистрации пользователя к нему на почту приходило сообщение для подтверждение почты, я подключил Celery(Redis). Но почему то сообщение на почту не отправляется, вот мой код: ...
ddos's user avatar
  • 13
0 голосов
1 ответ
105 показов

Как совершается очистка очереди от задач? / Как удалить задачу из брокера?

Я хочу автоматически очищать выполненные задачи( статус и id) из очереди. Результат задачи я очищаю автоматически прописав result_expires. Но айди и статус все еще в брокере, как это можно очистить? ...
Andy's user avatar
  • 19
0 голосов
0 ответов
57 показов

celery не видит задачу

main.py from celery import Celery app = Celery('first_step', backend='rpc://', broker='redis://localhost') app.conf.broker_url = 'redis://localhost:6379/0' @app.task def summary(x, y): return ...
Vladislav's user avatar
0 голосов
0 ответов
45 показов

Почему в Django не передаёт Celery task?

Запускаю в git codespace свой docker образ. Не понимаю, почему celery не выполняет ни один task. В логах контейнера web вижу nnpf-web-1 | [27/Mar/2023 21:54:44] "GET / HTTP/1.1" 200 4320 ...
egorrybko's user avatar
0 голосов
1 ответ
40 показов

Отмена задачи в Celery

В коде tasks.py Есть задача: def bar2(self, request): progress_recorder = ProgressRecorder(self) for i in range(7): if self.is_aborted(): return 'Таск остановлен!' ...
Денис's user avatar
0 голосов
0 ответов
19 показов

Почему celery дублирует сообщения на почте?

Сделал оповещения celery + redis, но сообщения на почту приходят вразнобой. То прилетают старые, то они дублируются celery.py import os from celery import Celery # Set the default Django settings ...
Kostay bagr's user avatar
0 голосов
1 ответ
52 показа

Подключить prometheus к celery-flower, запущенных в разных docker.compose.yml

Хочу подключит prometheus к celery-flower. Делаю всё по инструкции - https://github.com/mher/flower/blob/master/docs/prometheus-integration.rst Есть 2 docker-compose.yml. app/docker-compose.yml ...
m0nte-cr1st0's user avatar
0 голосов
0 ответов
48 показов

Потеря/незапуск таска в Celery (Django)

Всем привет! В проекте на Django есть одна модель Table (по сути - таблица), в зависимости от значения поля task_type при создании записи в таблице запускается один из двух обработчиков (PeriodicTask) ...
kolombina's user avatar
0 голосов
0 ответов
31 показ

Отслеживание прочтения письма email

Реализован сервис на django по рассылке сообщений на email пользователям. Как можно отследить, что письмо прочитано (открывалось)?
Евгений's user avatar
0 голосов
0 ответов
12 показов

Django Celery Rdis останавливается поле перезапуска beat

Есть сервис по парсингу сайтов, отправляет по несколько запросов на url с параметрами, и этот процесс длится 30 минут, если в это время когда отправляется запрос перезапустить beat то task исчезает (...
Numonjon's user avatar
0 голосов
0 ответов
64 показа

django-celery Не работает worker

Я установил celey, настроил django, поставил celey beat, все это запустилось. Метод выполнился 1 раз, и после этого у меня не работает worker. В качестве брокера использую redis. worker [2023-01-03 19:...
Александр's user avatar
0 голосов
0 ответов
33 показа

не получается запустить Django Celery на сервере Railway.app

Деплою Django проект на сервис railway.app. Сам Джанго запускается, всё ок, но не могу понять как мне запустить celery Пытался вот так, но таски не запускаются, и ошибок никаких не выдает file - ...
ralph_lauren's user avatar
1 голос
0 ответов
62 показа

Асинхронное получение статуса задачи Celery

Необходимо асинхронно получить статус задачи Celery. Попытался сделать это через run_in_executor, но поскольку для получения статуса используется property класса AsyncResult, то обернул вызов этого ...
Алексей's user avatar
1 голос
1 ответ
53 показа

Как запланировать задачу на Flask?

Пытаюсь организовать задачу, но если прохожу по ссылке /test_task, то пока все не отпринтуется - я не получу на странице результат {'status': True} from flask import Flask App = Flask(__name__) from ...
Алексей's user avatar
0 голосов
0 ответов
75 показов

missing 2 required positional arguments

пишу задачу для celory на ping всех датчиков, при получении их статуса, записываю его в базу данных, если датчик не ping, то присваиваю статус 'down' при запуске celery -A On_OFF_sensor beat -l info ...
Pitonch's user avatar
0 голосов
0 ответов
89 показов

Celery чтение/удаление множества записей

Есть приложение Django и таска в Celery, которая каждую минуту подсчитывает данные из PostgreSQL и удаляет уже подсчитанные данные и сразу отправляет результат работы на другой сервер. Все работает ...
Ivasik___2020's user avatar
0 голосов
1 ответ
55 показов

Celery не может найти django-приложение

Моя цель: настроить регулярное выполнение задачи через celery. Всё делаю по документации: https://docs.celeryq.dev/en/stable/django/first-steps-with-django.html#django-first-steps При запуске celery ...
Vladimir Kurbatov's user avatar
0 голосов
0 ответов
60 показов

ERROR: node with name "rabbit" is already running on host "DESKTOP-AL5T0M3"

Я пытаюсь запустить запустить команду rabbitmq-server и он мне выдает такую ошибку: 2022-10-02T17:48:19.962000+03:00 warning: FORMATTER CRASH: {"Using RABBITMQ_ADVANCED_CONFIG_FILE: ~s",[[...
Vadim Bagriy's user avatar
0 голосов
1 ответ
37 показов

Зачем после ajax запроса ставить celery?

Объясните пожалуйста, читаю статью https://habr.com/ru/company/otus/blog/503380/ там выполняется ajax запрос и после на сервере его ловит django и отправляет в celery. Вроде бы ajax и так асинхронный ...
Betflop's user avatar
  • 425
0 голосов
1 ответ
315 показов

Как настроить логирование Django + Celery с помощью RotatingFileHandler?

Есть сервис на Django (DRF), в котором настроена подсистема логирования. Также в сервисе есть Celery-воркер, который выполняет некоторую задачу. Я хочу настроить логирование таким образом, чтобы все ...
Sazoks's user avatar
  • 71
0 голосов
0 ответов
77 показов

Django + DRF + Celery: выполнить celery_task.delay() только после завершения транзакции (реального выполнения model.save())

Я пытался использовать указанный в доках метод on_commit, но всё равно внутри таска получаю ModelDoesNotExistError. views.py: class SomeViewset(viewsets.ModelViewset): ... @action(...
Jedi Knight's user avatar
0 голосов
0 ответов
31 показ

API Flower как отправить запрос

Пытаюсь через API Flower передать воркеру путь к папке /path/папка, Работает, только если в аргументах список с цифрами data = '{"args":[1,2]}' # если INT работает. Как сделать, чтобы в ...
Алексей С's user avatar
0 голосов
1 ответ
318 показов

Как использовать асинхронную функцию внутри задачи celery?

Я пишу бот в айограм, нашел несколько похожих вопросов, но не смог найти то, что мне нужно. У меня есть асинхронная функция, которую я хочу использовать в своей задаче celery, но не могу вызвать ее ...
mirodil's user avatar
  • 109
0 голосов
1 ответ
232 показа

Как корректно перезапустить celery worker?

Как перезапустить celery worker так чтобы все текущие задачи которые начали выполнение завершились, но новые не стартовали, чтобы можно было внести определенные корректировки и перезапустить?
Betflop's user avatar
  • 425
0 голосов
1 ответ
65 показов

При выполнении задачи по отправке sms задача печатается в консоль Celery и не отрабатывает

Вот мой код: project/__ init __.py from __future__ import absolute_import, unicode_literals from .celery import app as celery_app __all__ = ('celery_app',) celery.py from __future__ import ...
Rasim's user avatar
  • 30
0 голосов
0 ответов
34 показа

Celery не работает с брокером выдает эту ошибку, кто сталкировался с подобным можете помочь?

from flask import Flask from celery import Celery app = Flask(__name__) app.config['CELERY_BROKER_URL'] = 'redis://localhost:6379/0' app.config['RESULT_BACKEND'] = 'redis://localhost:6379/0' celery =...
Нурбек Нурбай's user avatar
0 голосов
1 ответ
191 показ

Периоды времени в celery add_periodic_task()

У меня в проекте есть код для запуска задач по времени: @app.on_after_finalize.connect def setup_periodic_tasks(sender, **kwargs): sender.add_periodic_task(60.0 * 10, update_info.signature(), name=...
Tritikale's user avatar
1 голос
1 ответ
657 показов

Можно ли выполнять таски в Celery по очереди?

Всем привет! У меня есть две таски download_and_send_youtube_video и clear_cache_youtube_video. Код: @celery.task def clear_cache_youtube_video(video_path: Path): """Clear YouTube ...
Dmitry Vasiliev's user avatar
0 голосов
0 ответов
54 показа

Функция в джанго не работает так как мне нужно

views from django.http import HttpResponse from .apps import price_info from poeproject.celery import app from .service import sk # Create your views here. items = [] @app.task def poe(): global ...
FORT's user avatar
  • 1
0 голосов
0 ответов
52 показа

Как изменить переменную с помощь функции в python?

tasks.py from .service import sk item = {} @app.task def poe(): global item item = sk() return item celery.py from celery import Celery from celery.schedules import crontab os.environ....
FORT's user avatar
  • 1
1 голос
0 ответов
51 показ

Ежечасное начисление баланса пользователя Django [закрыт]

У модели пользователя есть IntegerField, и надо, чтоб оно с определенного момента каждый час увеличивалось на 1000. Знаю, что это делается с помощью Celery, но как именно не понимаю
Юрий Кравченко's user avatar
0 голосов
0 ответов
666 показов

Как запустить Celery через Docker

Пишу сайт на Django, появилась потребность в асинхронных задачах, взялся за Celery. На локальном сервере всё работает корректно, но столкнулся с проблемой при переносе. При запуске worker'а на боевом ...
Виталий's user avatar
0 голосов
1 ответ
37 показов

Требует ли celery предварительного создания очередей

Требует ли celery обязательного предварительного создания очередей? Или можно запускать её и без них (для теста запуска сервиса).
vanorro228's user avatar
2 голоса
0 ответов
57 показов

python celery retry countdown

Ситуация: У меня работает одновременно порядка 100 задач. И в одной из них происходит ошибка, и я через function.retry(countdown=30) пытаюсь запустить заново таску через 30 секунд. Но через 30 секунд ...
Вадим Лепишко's user avatar
1 голос
0 ответов
323 показа

Django: Сохранение изображения из URL в ImageField

У меня есть модель Django с ImageField image = models.ImageField (upload_to = 'products /% Y /% m /% d') Все, что мне нужно сделать, это сохранить изображение со своего склада по уже существующему ...
Hey it's Serge's user avatar
0 голосов
1 ответ
117 показов

Очередь запросов на разные сервера

У меня есть сервер бэка на python и несколько серверов бд: <-> db -> backend <-> db <-> db Сейчас используется один сервер бд, мне нужно распараллелить ...
tetelevm's user avatar
  • 726
0 голосов
1 ответ
28 показов

celerybeat - отказано в доступе

Пытаюсь демонизировать celery beat. При запуске service celerybeat start вылетает ошибка env: /etc/init.d/celerybeat: Отказано в доступе Причем если запускать вручную, то celery запускается [root ...
Za Ars's user avatar
  • 4,071
0 голосов
0 ответов
126 показов

celery с версией 3.1.25 не работает

Я ещё новичок в celery поэтому решил пробовать максимально простой вариант. А именно сортировка чисел. Но и тут у меня не работает celery. Ранее уже гуглил и нашёл ответ что нужна версия 3.1.25! Так ...
JUST_PROGRAMMER's user avatar
-1 голос
1 ответ
178 показов

Celery - задачи выполнены, но результатов нет [закрыт]

Имеется странный кейс с Celery. ОС - Убунту, 8 ядер, Redis. Таска выполняет запрос к БД, и складывает данные в файлы на харде (по файлу на задачу). Отправляю 10 задач в очередь - в flower отмечены все ...
Georgy R.'s user avatar
  • 374
0 голосов
1 ответ
243 показа

Django автоматические джобы

Хочу реализовать такой функционал в django , что бы после деплоя на сервере работали автоматические джобы, которые будут выполнять определённый функционал (например каждый час создавать csv файл с ...
WilteRatenau's user avatar
1 голос
1 ответ
416 показов

Запуск параллельных воркеров в Celery

Необходим вызов 2-4 воркеров из существующего (главного) воркера с получением результатов. Схема работы: Основной воркер подготавливает задачи (долго) > 2-4 воркера (еще более долго, рандомное кол-...
Shershen's user avatar
1 голос
0 ответов
98 показов

Создание фоновых повторяющихся задач во flask

Необходимо сотворить управление (запускать и выключать) повторяющиеся фоновые задачи/таски. пример: есть на сайте кнопка "включить уведомление о новостях", при активации ее, пользователю ...
мне только спросить's user avatar
1 голос
0 ответов
203 показа

Как проверить работоспособность брокера RabbitMQ?

Установил RabbitMQ. Как проверить его работоспособность? Использовал в купе с celery. Но сейчас отказывается работать. Пишет, что удаленный сервер отклонил ответ. Сначала все было почти нормально, ...
Михаил Болеев's user avatar
0 голосов
0 ответов
66 показов

Ошибка redis и celery в docker контейнере

Запущена очередь задач celery-beat совместно с redis. Redis начал постоянно выдавать ошибку: Failed opening the RDB file root (in server root dir /etc) for saving: Permission denied redis | 1:M 16 ...
nortonts's user avatar
0 голосов
0 ответов
86 показов

Нет соединения с сервером. consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [WinError 10061]

Следовал инструкции по подключению celery здесь. Сначала все работало, задачи попадали в очередь, но не выполнялись. Переустановил celery (более современную версию) - все перестало работать. Пробовал ...
Михаил Болеев's user avatar