flask - 如何将(产生)文本数据流式传输到 pythonanywhere 上的 flask 应用程序的 jinja2 模板

Question

我尝试在我的 Pythonanywhere 帐户上实现“流媒体内容”。

它或多或少看起来像那里显示的内容:
参见http://flask.pocoo.org/docs/0.10/patterns/streaming/

除了我的 View 正在计算一个可能一分钟的复杂过程并将其数据生成到我的模板，其中脚本应该更新一些进度条(“source.onmessage”)。

这在我的开发机器上完美运行，但不适用于我的 pythonanywhere 帐户。在这台服务器上，进程看起来很卡(进度条永远不会更新，除非在最后突然从 0% 增长到 100%)，尽管一切都在后台进行，例如我的 print语句正确呈现到我的服务器日志中)。

在上面引用的片段中，有一个注释:

Note though that some WSGI middlewares might break streaming, so be careful there in debug environments with profilers and other things you might have enabled.

可能是这里的问题吗？会有解决方法吗？

我的 jinja2 模板中的 JS 代码:

    <script type="text/javascript">
    /* progress bar */
    var source = new EventSource("{{ url_for('BP.run', mylongprocess_id=mylongprocess_id) }}");
    source.onmessage = function(event) {
        console.log(event.data);
        var data = event.data.split("!!");
        var nodeid = data[0];
        var process = data[1];
        var process_status = data[2];
        var postpro = data[3];
        var postpro_status = data[4];
        $('.pb1').css('width', process+'%').attr('aria-valuenow', process);   
        $('.pb2').css('width', postpro+'%').attr('aria-valuenow', process);   
        document.getElementById("process_status").innerHTML = process_status;
        document.getElementById("postpro_status").innerHTML = postpro_status;
        document.getElementById("nodeid").innerHTML = nodeid;
        if (postpro >= 100) {
            setTimeout(function() {
                console.log("progress is finished!");
                document.getElementById("status").innerHTML = "redirecting to {{url_for('.view_sonix_result', mylongprocess_id=mylongprocess_id)}}";
                window.location.replace("{{url_for('.terminate_analysis', mylongprocess_id=mylongprocess_id)}}");
                                  }, 2); // / setTimeout function
            } // /if
        else {
            document.getElementById("status").innerHTML = "pending...";
            } // /else
        } // /function
</script>

我的(简化) View :

@BP.route('/run/<int:mylongprocess_id>')
@login_required
def run(mylongprocess_id):
    mylongprocess = mylongprocess.query.get_or_404(mylongprocess_id)
    project = Project.query.get_or_404(mylongprocess.project_id)
    check_rights(current_user, project, 'user', 404)
    A, lcs = _create_analysis(mylongprocess)
    @copy_current_request_context
    def gen(mylongprocess, nodeid, store_path):
        print('now runing %s' % A)
        for (loopnb, total_loops, pct, lclabel) in A.runiterator(lcs):
            print('ran %d/%d (%.1f%%) "%s"' % (loopnb, total_loops,
                                               pct, lclabel))
            progress = ('data: %s!!%f!!%s!!%f!!%s\n\n' %
                        (nodeid, pct, lclabel, 0, 'waiting...'))
            yield progress
        print('now postprocessing %s' % A)
        postpro = load_node(store_path, node_id=nodeid)
        for step, total, pct, action in postpro._builditer(target='web',
                                                       buildfile=None):
            progress = ('data: %s!!%f!!%s!!%f!!%s\n\n' %
                        (nodeid, 100, 'ok',  pct, action.replace('_', ' ')))
            yield progress
        print('now terminating %s' % A)
        _terminate_analysis(A, mylongprocess)

    return Response(gen(mylongprocess, mylongprocess.nodeid), mimetype='text/event-stream')

Answer 1

当您的流量托管在 PythonAnywhere 上时，您的流量会通过 nginx 代理，除非另有说明，否则 nginx 会缓冲响应。

为了让一切都冲洗干净，

给你的 flask 响应标题response.headers['X-Accel-Buffering'] = 'no'

有一个 '\n'在您正在生成的字符串的末尾，因为 python 也会缓冲到行尾。