Quart бесконечный / неопределенный поток - PullRequest
Новая
       49

Quart бесконечный / неопределенный поток

0 голосов
/ 31 октября 2018

Я пытаюсь создать сервер (свободно) на основе старого сообщения в блоге для потоковой передачи видео с помощью Quart.

Для потоковой передачи видео клиенту, похоже, все, что мне нужно сделать, - это найти маршрут, который возвращает генератор кадров. Однако в действительности это приводит к постоянному повторному сообщению socket.send() raised exception и отображает на клиенте испорченное изображение. После этого сервер не отвечает на дальнейшие запросы.

Используя больше вдохновения из исходного поста, я попытался вернуть Response (используя return Response(generator, mimetype="multipart/x-mixed-replace; boundary=frame").). Это действительно отображает видео на клиенте, но как только они отключаются (закройте вкладку, перейдите на другую страницу, и т. д.) сервер снова начинает рассылать спам socket.send() raised exception и не отвечает на дальнейшие запросы.

Мой код указан ниже. 

# in app.py
from camera_opencv import Camera
import os
from quart import (
    Quart,
    render_template,
    Response,
    send_from_directory,
)

app = Quart(__name__)

async def gen(c: Camera):
    for frame in c.frames():
        # d_frame = cv_processing.draw_debugs_jpegs(c.get_frame()[1])
        yield (b"--frame\r\nContent-Type: image/jpeg\r\n\r\n" + frame[0] + b"\r\n")


c_gen = gen(Camera(0))


@app.route("/video_feed")
async def feed():
    """Streaming route (img src)"""
    # return c_gen
    return Response(c_gen, mimetype="multipart/x-mixed-replace; boundary=frame")

# in camera_opencv.py
from asyncio import Event
import cv2

class Camera:
    last_frame = []

    def __init__(self, source: int):
        self.video_source = source
        self.cv2_cam = cv2.VideoCapture(self.video_source)
        self.event = Event()

    def set_video_source(self, source):
        self.video_source = source
        self.cv2_cam = cv2.VideoCapture(self.video_source)

    async def get_frame(self):
        await self.event.wait()
        self.event.clear()
        return Camera.last_frame

    def frames(self):
        if not self.cv2_cam.isOpened():
            raise RuntimeError("Could not start camera.")

        while True:
            # read current frame
            _, img = self.cv2_cam.read()

            # encode as a jpeg image and return it
            Camera.last_frame = [cv2.imencode(".jpg", img)[1].tobytes(), img]
            self.event.set()
            yield Camera.last_frame
        self.cv2_cam.release()

1 Ответ

0 голосов
/ 13 ноября 2018

Первоначально была проблема с самим Quart.

После раунда исправлений как Quart, так и Hypercorn код в виде опубликованных функций работает как задумано (по состоянию на 2018-11-13.)

...