Вопросы с меткой [celery]
Celery — это асинхронная распределенная очередь задач, построенная на передаче сообщений. Celery ориентирован на работу в режиме реального времени, но также поддерживает планирование.
120 вопросов
0
голосов
0
ответов
40
показов
Подскажите, как реализовать планировщик в fastapi
извините может за глупый вопрос, хочу узнать, как лучше сделать. У меня есть fastapi проект, мне надо сделать, чтобы каждые 5-ть минут выполнялось некое взаимодействие с сервисом и бд. У меня есть ...
- 1
0
голосов
0
ответов
77
показов
Airflow как супервизор
Можно ли использовать Аирфлоу для запуска задачи которая не завершается никогда?
С одной стороны она займет воркер: ну и ладно - добавим лишние. Но не будет ли ещё каких-то проблем? например, забитая ...
- 38.9k
0
голосов
1
ответ
70
показов
Ошибка asyncio при работе с БД: Future attached to a different loop
Именно при работе с БД, когда я запускаю asyncio.run в консоли пода или в самом приложении — первый раз запускается и отрабатывает нормально, на второй раз возникает эта ошибка:
RuntimeError: Task ...
- 3
0
голосов
1
ответ
51
показ
Event loop is closed
#celery_scheduler.py
from celery import Celery
from datetime import timedelta
from dotenv import load_dotenv
import os
load_dotenv(dotenv_path=os.path.join(os.path.dirname(__file__), "app", &...
0
голосов
1
ответ
30
показов
Запуск Celery и Celery Beat
Для работы Celery необходимо поднять worker и beat. Они поднимаются вручную в терминале, все работает, регламенты выполняются. Как сделать так, чтобы они запускались в фоне, типа как служба?
ОС Centos ...
0
голосов
0
ответов
70
показов
Как я могу улучшить свой код, чтобы избежать выброса floodcontrol при работе с vk_api?
Всем привет, я разрабатываю сервис для работы с vk. Ключевая задача этого сервиса - выкладывание историй в подключенные сообщества. Столкнулся с такой проблемой: Как не пытаюсь, все время вылетает ...
- 9
0
голосов
1
ответ
40
показов
после попытки контеризировать приложения события Celery перестали обрабатываться
я написал простой сайт на Django по покупке билетов, Celery когда пользователь начинает процесс оплаты места, оно бронируется. если через n секунд он все еще не оплатил - то оно освобождается с ...
1
голос
0
ответов
46
показов
Воркер Celery не закрывает соединения с Redis
Я создал тестовое приложение на Flask, которое использует Celery для асинхронной обработки его запросов. Когда я запускаю воркер celery, то по умолчанию создается 10 соединений celery с Redis, после ...
- 11
0
голосов
0
ответов
62
показа
scrapy-playwright не работает через celery в проекте django
Такая проблема - мне необходимо приложение на Scrapy-playwright для парсинга некоторых сайтов. В данном случае - ББР банка (Задание учебное, поэтому валюты подсасываются парсингом - задание препода)
...
- 11
1
голос
1
ответ
83
показа
Как лучше всего уведомлять пользователя об истечении подписки
У меня есть телеграм бот, в котором у меня есть пользователи, которые имеют подписку на бота. Я хочу уведомлять пользователя, если до истечения подписки остаётся к примеру неделя. Как мне лучше ...
user589577
2
голоса
2
ответа
265
показов
Почему отложенное задание от celery срабатывает через раз?
Я сделал таск, который, по логике, должен был удалять событие с истекшим временем. Но, когда таск проходит 2 раз после предыдущего раза, он вызывает одну и ту же ошибку с закрытием обработчика.
tasks/...
- 113
1
голос
1
ответ
94
показа
Celery не может подключится к Postgres Django
Проблема заключается в том, что контейнер Celery не может подключится к базе данных Postgres, когда начинает выполнять таску. В чем может быть проблема?
При отправке таски выдает такую ошибку - django....
user565235
1
голос
0
ответов
35
показов
Как представить, генерировать и хранить workflow в виде графа, для его последующего использования celery
Как workflow с последовательностями задач и групповыми задачами (представленный в виде графа) хранить в бд(postgresql или другой), и запускать когда происходит какое-либо событие (слушается Kafka).
...
0
голосов
0
ответов
209
показов
Celery beat не запускается
Имеется проект, в котором использую Celery beat планировщик.
Код:
from celery.schedules import crontab
app.conf.beat_schedule = {
'run-every-midnight': {
'task': 'celery_tasks.app....
- 16
0
голосов
0
ответов
71
показ
Структура проекта django с постоянно работающим воркером
Мне нужен совет по структуре проекта.
У меня есть скрипт-воркер, который постоянно держит коннект со SteamAPI под логином и паролем для того, чтобы получать данные о пользователях и заполнять ими html....
- 1