Вопросы с меткой [celery]
Celery — это асинхронная распределенная очередь задач, построенная на передаче сообщений. Celery ориентирован на работу в режиме реального времени, но также поддерживает планирование.
114
вопросов
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):
# Список подписчиков на ...
0
голосов
0
ответов
25
показов
Как интегрировать отправку OTP с Celery в проект?
Вот мой viewset и serialsers. Я хочу интегрировать отправку OTP во время авторизации пользователя. Чтобы пройти успешную авторизацию, нужно ввести 6-ти значный OTP код. Как мне лучше это сделать? ...
0
голосов
0
ответов
27
показов
Не работает вызов функции через Celery
Хочу написать небольшую апишку на flask, которая при переходе на /get_domain_users будет вызывать асинхронную функцию при помощи Celery, чтобы получить данные из бд и закинуть в json, который ...
1
голос
0
ответов
31
показ
Celery не находит модели при выполнении задачи
Пишу Api для телефонной рассылки, мой код принимает заявки на рассылку и когда настает время начала рассылки он отправляет запрос на внешнюю Api, которая в свою очередь отправляет сами сообщения.
Если ...
0
голосов
0
ответов
18
показов
ResultMissing при выполнении задачи Dramatiq
Для своего проекта (бэкенд интернет-магазина на Django) я реализовал имитацию оплаты заказа. Для практики решил использовать Dramatiq, чтобы потренироваться с асинхронным выполнением задач. Вот мой ...
1
голос
1
ответ
170
показов
Django+Celery не выполняется task
Я хочу сделал так что при регистрации пользователя к нему на почту приходило сообщение для подтверждение почты, я подключил Celery(Redis). Но почему то сообщение на почту не отправляется, вот мой код:
...
0
голосов
1
ответ
105
показов
Как совершается очистка очереди от задач? / Как удалить задачу из брокера?
Я хочу автоматически очищать выполненные задачи( статус и id) из очереди. Результат задачи я очищаю автоматически прописав result_expires.
Но айди и статус все еще в брокере, как это можно очистить? ...
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 ...
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
...
0
голосов
1
ответ
40
показов
Отмена задачи в Celery
В коде tasks.py Есть задача:
def bar2(self, request):
progress_recorder = ProgressRecorder(self)
for i in range(7):
if self.is_aborted():
return 'Таск остановлен!'
...
0
голосов
0
ответов
19
показов
Почему celery дублирует сообщения на почте?
Сделал оповещения celery + redis, но сообщения на почту приходят вразнобой. То прилетают старые, то они дублируются
celery.py
import os
from celery import Celery
# Set the default Django settings ...
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
...
0
голосов
0
ответов
48
показов
Потеря/незапуск таска в Celery (Django)
Всем привет!
В проекте на Django есть одна модель Table (по сути - таблица), в зависимости от значения поля task_type при создании записи в таблице запускается один из двух обработчиков (PeriodicTask) ...
0
голосов
0
ответов
31
показ
Отслеживание прочтения письма email
Реализован сервис на django по рассылке сообщений на email пользователям. Как можно отследить, что письмо прочитано (открывалось)?
0
голосов
0
ответов
12
показов
Django Celery Rdis останавливается поле перезапуска beat
Есть сервис по парсингу сайтов, отправляет по несколько запросов на url с параметрами,
и этот процесс длится 30 минут, если в это время когда отправляется запрос перезапустить beat то task исчезает (...
0
голосов
0
ответов
64
показа
django-celery Не работает worker
Я установил celey, настроил django, поставил celey beat, все это запустилось. Метод выполнился 1 раз, и после этого у меня не работает worker.
В качестве брокера использую redis.
worker
[2023-01-03 19:...
0
голосов
0
ответов
33
показа
не получается запустить Django Celery на сервере Railway.app
Деплою Django проект на сервис railway.app. Сам Джанго запускается, всё ок, но не могу понять как мне запустить celery
Пытался вот так, но таски не запускаются, и ошибок никаких не выдает
file - ...
1
голос
0
ответов
62
показа
Асинхронное получение статуса задачи Celery
Необходимо асинхронно получить статус задачи Celery.
Попытался сделать это через run_in_executor, но поскольку для получения статуса используется property класса AsyncResult, то обернул вызов этого ...
1
голос
1
ответ
53
показа
Как запланировать задачу на Flask?
Пытаюсь организовать задачу, но если прохожу по ссылке /test_task, то пока все не отпринтуется - я не получу на странице результат {'status': True}
from flask import Flask
App = Flask(__name__)
from ...
0
голосов
0
ответов
75
показов
missing 2 required positional arguments
пишу задачу для celory на ping всех датчиков, при получении их статуса, записываю его в базу данных, если датчик не ping, то присваиваю статус 'down'
при запуске celery -A On_OFF_sensor beat -l info
...
0
голосов
0
ответов
89
показов
Celery чтение/удаление множества записей
Есть приложение Django и таска в Celery, которая каждую минуту подсчитывает данные из
PostgreSQL и удаляет уже подсчитанные данные и сразу отправляет результат работы на другой сервер.
Все работает ...
0
голосов
1
ответ
55
показов
Celery не может найти django-приложение
Моя цель: настроить регулярное выполнение задачи через celery.
Всё делаю по документации: https://docs.celeryq.dev/en/stable/django/first-steps-with-django.html#django-first-steps
При запуске celery ...
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",[[...
0
голосов
1
ответ
37
показов
Зачем после ajax запроса ставить celery?
Объясните пожалуйста, читаю статью https://habr.com/ru/company/otus/blog/503380/ там выполняется ajax запрос и после на сервере его ловит django и отправляет в celery.
Вроде бы ajax и так асинхронный ...
0
голосов
1
ответ
315
показов
Как настроить логирование Django + Celery с помощью RotatingFileHandler?
Есть сервис на Django (DRF), в котором настроена подсистема логирования. Также в сервисе есть Celery-воркер, который выполняет некоторую задачу. Я хочу настроить логирование таким образом, чтобы все ...
0
голосов
0
ответов
77
показов
Django + DRF + Celery: выполнить celery_task.delay() только после завершения транзакции (реального выполнения model.save())
Я пытался использовать указанный в доках метод on_commit, но всё равно внутри таска получаю ModelDoesNotExistError.
views.py:
class SomeViewset(viewsets.ModelViewset):
...
@action(...
0
голосов
0
ответов
31
показ
API Flower как отправить запрос
Пытаюсь через API Flower передать воркеру путь к папке /path/папка,
Работает, только если в аргументах список с цифрами data = '{"args":[1,2]}' # если INT работает.
Как сделать, чтобы в ...
0
голосов
1
ответ
318
показов
Как использовать асинхронную функцию внутри задачи celery?
Я пишу бот в айограм, нашел несколько похожих вопросов, но не смог найти то, что мне нужно.
У меня есть асинхронная функция, которую я хочу использовать в своей задаче celery, но не могу вызвать ее ...
0
голосов
1
ответ
232
показа
Как корректно перезапустить celery worker?
Как перезапустить celery worker так чтобы все текущие задачи которые начали выполнение завершились, но новые не стартовали, чтобы можно было внести определенные корректировки и перезапустить?
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 ...
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 =...
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=...
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 ...
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 ...
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....
1
голос
0
ответов
51
показ
Ежечасное начисление баланса пользователя Django [закрыт]
У модели пользователя есть IntegerField, и надо, чтоб оно с определенного момента каждый час увеличивалось на 1000. Знаю, что это делается с помощью Celery, но как именно не понимаю
0
голосов
0
ответов
666
показов
Как запустить Celery через Docker
Пишу сайт на Django, появилась потребность в асинхронных задачах, взялся за Celery. На локальном сервере всё работает корректно, но столкнулся с проблемой при переносе.
При запуске worker'а на боевом ...
0
голосов
1
ответ
37
показов
Требует ли celery предварительного создания очередей
Требует ли celery обязательного предварительного создания очередей?
Или можно запускать её и без них (для теста запуска сервиса).
2
голоса
0
ответов
57
показов
python celery retry countdown
Ситуация:
У меня работает одновременно порядка 100 задач. И в одной из них происходит ошибка, и я через function.retry(countdown=30) пытаюсь запустить заново таску через 30 секунд. Но через 30 секунд ...
1
голос
0
ответов
323
показа
Django: Сохранение изображения из URL в ImageField
У меня есть модель Django с ImageField
image = models.ImageField (upload_to = 'products /% Y /% m /% d')
Все, что мне нужно сделать, это сохранить изображение со своего склада по уже существующему ...
0
голосов
1
ответ
117
показов
Очередь запросов на разные сервера
У меня есть сервер бэка на python и несколько серверов бд:
<-> db
-> backend <-> db
<-> db
Сейчас используется один сервер бд, мне нужно распараллелить ...
0
голосов
1
ответ
28
показов
celerybeat - отказано в доступе
Пытаюсь демонизировать celery beat.
При запуске service celerybeat start вылетает ошибка
env: /etc/init.d/celerybeat: Отказано в доступе
Причем если запускать вручную, то celery запускается
[root ...
0
голосов
0
ответов
126
показов
celery с версией 3.1.25 не работает
Я ещё новичок в celery поэтому решил пробовать максимально простой вариант. А именно сортировка чисел. Но и тут у меня не работает celery. Ранее уже гуглил и нашёл ответ что нужна версия 3.1.25! Так ...
-1
голос
1
ответ
178
показов
Celery - задачи выполнены, но результатов нет [закрыт]
Имеется странный кейс с Celery.
ОС - Убунту, 8 ядер, Redis.
Таска выполняет запрос к БД, и складывает данные в файлы на харде (по файлу на задачу). Отправляю 10 задач в очередь - в flower отмечены все ...
0
голосов
1
ответ
243
показа
Django автоматические джобы
Хочу реализовать такой функционал в django , что бы после деплоя на сервере работали автоматические джобы, которые будут выполнять определённый функционал (например каждый час создавать csv файл с ...
1
голос
1
ответ
416
показов
Запуск параллельных воркеров в Celery
Необходим вызов 2-4 воркеров из существующего (главного) воркера с получением результатов.
Схема работы:
Основной воркер подготавливает задачи (долго) > 2-4 воркера (еще более долго, рандомное кол-...
1
голос
0
ответов
98
показов
Создание фоновых повторяющихся задач во flask
Необходимо сотворить управление (запускать и выключать) повторяющиеся фоновые задачи/таски.
пример: есть на сайте кнопка "включить уведомление о новостях", при активации ее, пользователю ...
1
голос
0
ответов
203
показа
Как проверить работоспособность брокера RabbitMQ?
Установил RabbitMQ. Как проверить его работоспособность? Использовал в купе с celery. Но сейчас отказывается работать. Пишет, что удаленный сервер отклонил ответ. Сначала все было почти нормально, ...
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 ...
0
голосов
0
ответов
86
показов
Нет соединения с сервером. consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [WinError 10061]
Следовал инструкции по подключению celery здесь. Сначала все работало, задачи попадали в очередь, но не выполнялись. Переустановил celery (более современную версию) - все перестало работать. Пробовал ...