Потоковая передача нескольких видеопотоков через FASTAPI вызывает запасы HTTP ⇐ Python

[Anonymous]

У меня есть большое приложение Fastapi. Есть много разных конечных точек, в том числе одна, которая используется для прокси -потоков. Использование - это примерно так: конечная точка получает URL -адрес видеопотока, открывает его и возвращает его через потоковую реакцию. Если я прокси -6 потоки, то мое приложение FastApi перестает принимать какие -либо дополнительные запросы, пока я не закрою один из открытых потоков в браузере. Потоки, но проблема уже возникает при прокси 6. Как это исправить? Я отмечу, что нет проблем с исходными потоками, они работают непосредственно в любом количестве.import uvicorn
import httpx
from fastapi import FastAPI
from fastapi.responses import StreamingResponse

app = FastAPI()

async def proxy_mjpeg_stream(url: str):

async with httpx.AsyncClient() as client:
try:
async with client.stream("GET", url) as stream:
async for chunk in stream.aiter_bytes():
if chunk:
yield chunk
except httpx.ReadTimeout as ER:
print(f'ERROR ReadTimeout - {url=} - {ER}')

@app.get("/get_stream")
async def get_stream(url: str):
if url:
headers = {
"Content-Type": 'multipart/x-mixed-replace; boundary=frame',
}
return StreamingResponse(proxy_mjpeg_stream(url), headers=headers)

if __name__ == "__main__":
uvicorn.run(app)



Подробнее здесь: https://stackoverflow.com/questions/793 ... s-stalling