У меня есть большое серверное приложение на 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
Программы на Python
-
Anonymous
1737711637
Anonymous
У меня есть большое серверное приложение на 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)
Подробнее здесь: [url]https://stackoverflow.com/questions/79383867/problem-with-proxying-multiple-video-streams-via-fastapi[/url]
Ответить
1 сообщение
• Страница 1 из 1
Перейти
- Кемерово-IT
- ↳ Javascript
- ↳ C#
- ↳ JAVA
- ↳ Elasticsearch aggregation
- ↳ Python
- ↳ Php
- ↳ Android
- ↳ Html
- ↳ Jquery
- ↳ C++
- ↳ IOS
- ↳ CSS
- ↳ Excel
- ↳ Linux
- ↳ Apache
- ↳ MySql
- Детский мир
- Для души
- ↳ Музыкальные инструменты даром
- ↳ Печатная продукция даром
- Внешняя красота и здоровье
- ↳ Одежда и обувь для взрослых даром
- ↳ Товары для здоровья
- ↳ Физкультура и спорт
- Техника - даром!
- ↳ Автомобилистам
- ↳ Компьютерная техника
- ↳ Плиты: газовые и электрические
- ↳ Холодильники
- ↳ Стиральные машины
- ↳ Телевизоры
- ↳ Телефоны, смартфоны, плашеты
- ↳ Швейные машинки
- ↳ Прочая электроника и техника
- ↳ Фототехника
- Ремонт и интерьер
- ↳ Стройматериалы, инструмент
- ↳ Мебель и предметы интерьера даром
- ↳ Cантехника
- Другие темы
- ↳ Разное даром
- ↳ Давай меняться!
- ↳ Отдам\возьму за копеечку
- ↳ Работа и подработка в Кемерове
- ↳ Давай с тобой поговорим...
Мобильная версия