У меня есть большое серверное приложение на Python + fastapi. Существует много разных конечных точек, включая ту, которая используется для проксирования видеопотоков. Использование примерно такое: конечная точка получает URL-адрес видеопотока, открывает его и передает через потоковый ответ. Если проксирую 5 видеопотоков, то все нормально. Если я проксирую 6 потоков, то мое приложение Python перестанет принимать любые запросы на отдых, пока я не закрою один из открытых потоков в браузере.
Мне нужно будет проксировать гораздо большее количество видеопотоков, но проблема возникает уже тогда, когда проксирование 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 ... ia-fastapi
Проблема с проксированием нескольких видеопотоков через FastApi. ⇐ Python
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение
-
-
Потоковая передача нескольких видеопотоков через FASTAPI вызывает запасы HTTP
Anonymous » » в форуме Python - 0 Ответы
- 17 Просмотры
-
Последнее сообщение Anonymous
-
-
-
Способ извлечения видеопотоков из двоичного/исполняемого файла [закрыто]
Anonymous » » в форуме JAVA - 0 Ответы
- 13 Просмотры
-
Последнее сообщение Anonymous
-