именно у меня было ожидание, что фоновая таска должна запустится в отдельном Thread и например при выполнении подобного кода
def process_file(file_id: str):
# This is where you would do the actual file processing
# In this example, we'll just simulate a delay
time.sleep(15)
print(f"File with ID {file_id} has been processed.")
@router.post("/upload-file/")
async def upload_file(background_tasks: BackgroundTasks):
# This is where you would handle the file upload
# In this example, we'll just assume that the file ID is passed as a parameter
file_id = "1234"
# Initiate a background task to process the file
background_tasks.add_task(process_file, file_id)
# Return a response to the user
return {"message": f"File with ID {file_id} has been uploaded and is being processed in the background."}
Таска с timer.sleep(10) должна запускаться в фоне и не блокировать Main thread, но она блокирует и пока выполняется эта таска, аппликейшен не принимает больше запросов.
Так и задумано?
а в чем проблема тут асинхронно сохранять файл?
проверил, вроде ничего не блочится, обрабатывает другой запрос
вот весь код. дергаю в docs upload_file, потом много раз get_time и ничего не тормозит (причем в любой из комбинаций async def или обычного def для этих 2х эндпоинтов. но правильнее конечно просто def, как написано в доке, если внутри ничего асинхронного не делаем) а чем отличается ваш код? наверно стопорится по какой-то другой причине.. import time import datetime from fastapi import FastAPI, BackgroundTasks app = FastAPI() def process_file(file_id: str): time.sleep(15) print(f"File with ID {file_id} has been processed.") @app.get("/get_time") def get_time(): return datetime.datetime.now() @app.post("/upload-file/") def upload_file(background_tasks: BackgroundTasks): file_id = "1234" background_tasks.add_task(process_file, file_id) return {"message": f"File with ID {file_id} has been uploaded"}
Да, магия какая то, я создал новый проект с нуля и там работает, а в моем текущем тот же самый код - нет. Вот дебажу в чем различие...
если там что-то вроде такого скинете на пастбин? или там реальный проект а код выше был для примера?
Кароче в моём случае оказался вот этот кноун баг: https://github.com/encode/starlette/issues/919 "When using background tasks with middleware, requests are not processed until the background task has finished."
Обсуждают сегодня