У меня есть fastapi приложение которое запускается, и в фоне

Question

У меня есть fastapi приложение которое запускается, и в фоне

я создаю таску которая раз в N времени что-то стягивает, но перестаёт работает reload и приложение фризится, как это пофиксить?
Сама таска:
async def task():
while True:
await collect_data()
await asyncio.sleep(1)

#backend #programming #python #russian

0

22.12.2021

10 ответов

22 просмотра

Ihor 🐈 C.

В fastapi_utils.tasks есть repeat_every декоратор, и тебе не нужен вайл тру со слипом.

0

22.12.2021

Ruslan Chernenko

Я бы на твоём месте подумал про селери

0

22.12.2021

smqwe Автор вопроса

Ruslan Chernenko
Я бы на твоём месте подумал про селери

))

0

22.12.2021

Ruslan Chernenko

smqwe
))

Ну просто поедставь, что у тебя твоя таска ивент луп весь сожрёт, и не отдаст никогда

0

22.12.2021

smqwe Автор вопроса

Ihor 🐈 C.
В fastapi_utils.tasks есть repeat_every декоратор,...

а там можно запускать каждые 0,5 секунд например, в доке найти не могу

0

22.12.2021

Ihor 🐈 C.

Если смущает строчка дальше, то тебе действительно нужно распараллеливание process-based, как выше предлагали, через селери

0

22.12.2021

smqwe Автор вопроса

Ihor 🐈 C.
Если смущает строчка дальше, то тебе действительно...

да я уверен, что есть другое решение под капотом. У нас же условно есть asyncio.call_later, я полагаю, что есть что-то похожее но не требующее рекурсии, celery тут не надо

0

22.12.2021

Ihor 🐈 C.

smqwe
да я уверен, что есть другое решение под капотом. ...

В таком случае, нужно быть уверенным, что collect_data не станет боттл-неком

0

22.12.2021

smqwe Автор вопроса

Ihor 🐈 C.
В таком случае, нужно быть уверенным, что collect_...

так там под капотом тот же самый while True)

0

22.12.2021