Flask：从生成器流到 jQuery/$.post() 并产生答案

【问题标题】：Flask: stream to jQuery/$.post() from generator with yieldFlask：从生成器流到 jQuery/$.post() 并产生
【发布时间】：2013-06-18 20:51:57
【问题描述】：

在我用 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？

【问题讨论】：

标签： jquery json flask

【解决方案1】：

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

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

【讨论】：

这对我不起作用。 event_stream 只是做它的事情，onmessage 事件处理程序永远不会被触发。除非我在所有onmessage 事件触发后立即停止烧瓶进程。这似乎违背了流式传输的目的，因为您只有在流运行完成后才能获得所有结果。还不如把所有东西都拿回来。还是我错过了什么？

【解决方案2】：

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

您可以尝试使用XMLHttpRequest2.progress event、ProgressEvent.loaded 并从XMLHttpRequest2.response 读取数据，但是何时处理此事件是一个非常棘手的问题（尤其是对于每个浏览器）。
您也可以尝试查看WebRTC，但这存在浏览器支持的限制，并且对于您的情况来说看起来非常困难。
不要忘记flash 等，但对于您的情况来说，这看起来也非常困难。

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

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

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

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

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

您下载或上传大文件并希望在flask应用程序中控制速度（用户引用，不要使用所有通道进行此操作）。但是如果你使用例如uwsgi这个操作处理时你的进程或线程将被阻塞。
您下载或上传大文件并希望停止/恢复/验证此操作。

【讨论】：

我想办法是在后台移动长时间运行的进程，将所有内容保存在redis中并让客户端不断更新。 Web 套接字或类似的东西是矫枉过正:)