7

在我用 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”，而不是每个产量的两个单独的警报。所以回调函数在一切都“屈服”后被调用。

如何正确流式传输到 jQuery？

4

2 回答 2

8

在这种情况下，您可以使用服务器发送的事件。查看下面的示例：

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

于 2013-06-19T08:47:10.393 回答
3

这是一个 AJAX 请求，您alert在加载所有数据时进行处理。您无法获得单独的块，因为它是一个请求，但可以尝试模拟：

  1. 您可以尝试使用XMLHttpRequest2.progressevent，ProgressEvent.loaded并从中读取数据XMLHttpRequest2.response，但是何时处理此事件是非常困难的问题（尤其是对于每个浏览器）。

  2. 您也可以尝试查看，WebRTC但这存在浏览器支持的限制，并且对于您的情况来说看起来非常困难。

  3. 不要忘记flash等等，但对于您的情况来说，这看起来也非常困难。

如果您的响应很快，那么您可以在客户端获得所有响应和单独的数据（例如，如果您知道 blob 结构，您可以将 json 与 base64 用于二进制对象或 blob）。

如果您的响应很长，因为您获得了大数据并且您确实需要块，那么最好发出多个请求，因为新连接的时间将少于加载大块的时间。在这种情况下，最好不要为 AJAX 使用大块，因为它会引发timeout异常。

如果您的响应很长，因为它占用大量 CPU 或操作缓慢，那么最好启动后台进程（如celery），返回响应并在一段时间后检查结果。

如果您必须非常快地得到响应，您可以尝试使用web sockets（在这种情况下，您已经必须发送不同的消息）。

因此，当流式传输和块会有所帮助时：

  1. 您下载或上传大文件并希望在烧瓶应用程序中控制速度（用户引用，不要使用所有通道进行此操作）。但是如果你使用例如uwsgi你的进程或线程在这个操作处理时会被阻塞。
  2. 您下载或上传大文件并希望停止/恢复/验证此操作。
于 2013-06-19T08:34:54.753 回答