在使用jQuery $ .post()调用函数后,我想从烧瓶中的生成器传输数据块:
@app.route('/some/function', methods=['POST'])
def calculateSomething():
def g():
# do something here
yield 'result1'
# do more ...
yield 'result2'
return Response(g())
我从jQuery调用这个函数:
$.post("/some/function", {"some": $data}, function(data) {
alert(result)
})
这只给我一个警告说'result1result2',而不是每个产量的两个单独的警报.因此,在所有内容都"生成"之后调用回调函数.
如何正确地使用yield流式传输到jQuery？
在这种情况下,您可以使用服务器发送的事件.看看下面的示例:
from flask import Flask, Response
import time
app = Flask(__name__)
@app.route('/')
def index():
return """
<!DOCTYPE html>
<html>
<head>
<script>
if(typeof(EventSource)!=="undefined") {
var source=new EventSource("/stream");
source.onmessage=function(event) {
document.getElementById("result").innerHTML+=event.data + "<br>";
};
} else {
document.getElementById("result").innerHTML="Sorry, your browser does not support server-sent events...";
}
</script>
</head>
<body>
<h1>Data</h1>
<div id="result"></div>
</body>
</html>
"""
@app.route('/stream', methods=['GET', 'POST'])
def stream():
def event_stream():
n = 0
while True:
yield "data: %s\n\n" % n
n += 1
time.sleep(1)
return Response(event_stream(), mimetype='text/event-stream')
if __name__ == '__main__':
app.run()
服务器发送事件会阻止您的开发服 要处理多个连接,请查看使用Gevent.http://flask.pocoo.org/docs/deploying/others/#gevent
这是一个 AJAX 请求，您将alert在加载所有数据时进行处理。您无法获得单独的块，因为它是一个请求，但可以尝试模拟这一点：
您可以尝试使用XMLHttpRequest2.progressevent，ProgressEvent.loaded并从中读取数据XMLHttpRequest2.response，但是何时处理此事件是一个非常困难的问题（特别是对于每个浏览器）。
您也可以尝试查看，WebRTC但这存在浏览器支持的限制，并且对于您的情况来说看起来非常困难。
不要忘记flash等等，但对于您的情况来说，这看起来也非常困难。
如果您的响应速度很快，那么您可以在客户端上获取所有响应和单独的数据（例如，如果您知道 blob 结构，您可以使用带有 base64 的 json 来表示二进制对象或 blob）。
如果您的响应很长，因为您获得了大数据并且您确实需要块，那么最好发出多个请求，因为新连接的时间将少于大块加载的时间。在这种情况下，最好不要对 AJAX 使用大块，因为它可能会引发timeout异常。
如果您的响应很长，因为它需要大量 CPU 或操作缓慢，那么最好启动后台进程（如celery），返回响应并在一定时间间隔后检查结果。
如果您必须非常快地得到响应，您可以尝试使用web sockets（在这种情况下您已经必须发送不同的消息）。
因此，当流和块会有所帮助时：
uwsgi您的进程或线程将在该操作处理时被阻塞。