对不起我的英语技能。我想创建一个流式传输视频并运行多个功能的网页。我正在使用python和flask服务器。但是,有些问题我无法单独解决。我有一个源代码。它几乎是完美的。
源代码。
import time
from flask import Flask, render_template, Response
from camera import Camera
app = Flask(__name__)
@app.route('/')
def index():
return render_template('index.html')
def gen(camera):
while True:
frame = camera.get_frame()
yield (b'--frame\r\n'
b'Content-Type: image/jpeg\r\n\r\n' + frame + b'\r\n')
@app.route('/video_feed')
def video_feed():
return Response(gen(Camera()),
mimetype='multipart/x-mixed-replace; boundary=frame')
@app.route('/test')
def test():
return time.time()
if __name__ == '__main__':
app.run(host='0.0.0.0', debug=True
和模板
<html>
<head>
<title>Video Streaming Demonstration</title>
</head>
<body>
<h1>Video Streaming Demonstration</h1>
<img src="{{ url_for('video_feed') }}">
</body>
</html>
在源代码中,名为gen()的函数使用'yield'。所以,它永远不会结束。它占用了所有资源。我希望在视频流式传输时运行另一个类似'test'功能的功能。
视频流需要与客户端建立永久连接。如果您使用Flask开发Web服务器执行此操作,则无法处理任何其他请求,因为默认情况下该服务器一次处理一个连接。
如果要同时处理多个连接,可以使用几个选项。最简单(但不是非常强大或高效)是以线程模式运行开发服务器(只需在threaded=True
调用中添加app.run()
)。这将为传入的请求生成新线程。更加生产就绪的解决方案是切换到不同的Web服务器。例如,使用gunicorn,您可以控制启动的工作进程数。为了更加灵活,诸如gevent之类的服务器可以处理大量并发客户端请求。
您可以像这样控制生成器的行为:
import time
start_time = time.time()
def first():
while True:
yield 'frame'
def second():
while True:
yield time.time()
init = [first(),second()]
def handler():
#handling logic
global start_time
while True:
try:
res = map(lambda x: x.next(),init)
if res[1] - start_time > 10: break
print res[1] - start_time
except StopIteration:
break
handler()
此代码将产生自脚本启动以来的时间与可能是任何数据的虚构帧之间的差异。