这是基于发布的答案https://stackoverflow.com/a/13388915/819544 https://stackoverflow.com/a/13388915/819544
我想监视数据流并将其推送到类似于上面答案的前端，但是一旦应用程序启动，流就开始生成/监视数据，并且客户端始终会看到该数据流的当前状态数据流（无论是否从服务器请求数据，数据流都会保持运行）。
我很确定我需要通过线程将数据流与前端分离，但我对线程/异步编程不太熟悉，并且相信我做错了。也许代替threading我需要使用多处理吗？这大致是我想要做的（根据上面链接的答案修改）：
app.py
#!/usr/bin/env python
from __future__ import division
import itertools
import time
from flask import Flask, Response, redirect, request, url_for
from random import gauss
import threading
app = Flask(__name__)
# Generate streaming data and calculate statistics from it
class MyStreamMonitor(object):
def __init__(self):
self.sum = 0
self.count = 0
@property
def mu(self):
try:
outv = self.sum/self.count
except:
outv = 0
return outv
def generate_values(self):
while True:
time.sleep(.1) # an artificial delay
yield gauss(0,1)
def monitor(self, report_interval=1):
print "Starting data stream..."
for x in self.generate_values():
self.sum += x
self.count += 1
stream = MyStreamMonitor()
@app.route('/')
def index():
if request.headers.get('accept') == 'text/event-stream':
def events():
while True:
yield "data: %s %d\n\n" % (stream.count, stream.mu)
time.sleep(.01) # artificial delay. would rather push whenever values are updated.
return Response(events(), content_type='text/event-stream')
return redirect(url_for('static', filename='index.html'))
if __name__ == "__main__":
# Data monitor should start as soon as the app is started.
t = threading.Thread(target=stream.monitor() )
t.start()
print "Starting webapp..." # we never get to this point.
app.run(host='localhost', port=23423)
static/index.html
<!doctype html>
<title>Server Send Events Demo</title>
<style>
#data {
text-align: center;
}
</style>
<script src="http://code.jquery.com/jquery-latest.js"></script>
<script>
if (!!window.EventSource) {
var source = new EventSource('/');
source.onmessage = function(e) {
$("#data").text(e.data);
}
}
</script>
<div id="data">nothing received yet</div>
这段代码不起作用。 “正在启动 webapp...”消息永远不会打印，正常的 Flask 消息也不会打印，并且访问提供的 URL 会确认应用程序没有运行。
如何让数据监视器在后台运行，以便 Flask 可以访问它看到的值并将当前状态推送到客户端（甚至更好：只要客户端正在侦听，就推送当前状态相关值发生变化）？
