当线程完成时,如何更改 Flask 中的渲染模板?

Apa*_*ara 3 python multithreading heroku backgroundworker flask

我有一个功能可以在网络上抓取数据并计算搜索分数。但是,这可能需要一段时间,有时网页会在完成执行之前超时。

因此,我创建了一个单独的线程来执行该函数并loading.html告诉客户端仍在收集数据。一旦函数在线程中结束,我如何重新加载网页以显示output.html显示分数。

这是我迄今为止所拥有的一个更简单的版本:

from flask import Flask
from flask import render_template
from threading import Thread

app = Flask(__name__)

@app.route("/")
def init():
    return render_template('index.html')

@app.route("/", methods=['POST'])
def load():
    th = Thread(target=something, args=())
    th.start()
    return render_template('loading.html')

def something():
    #do some calculation and return the needed value

if __name__ == "__main__":
    app.run()
Run Code Online (Sandbox Code Playgroud)

如何 在线程完成render_template('output.html', x=score) 后将我的应用程序路由到一次?something()th

我试图避免像 redis 这样的任务队列,因为我想在网络上部署这个应用程序,我不想产生费用(这更像是一种实验和爱好)。

详细的代码答案会很有帮助,因为我是烧瓶和多线程的新手

MrL*_*eeh 5

一种简单的方法是向thread_status端点发出循环 Ajax 请求,该端点为您提供有关当前正在运行的任务的信息。

import time
from flask import Flask, jsonify
from flask import render_template
from threading import Thread

app = Flask(__name__)
th = Thread()
finished = False


@app.route("/")
def init():
    return render_template('index.html')


@app.route("/", methods=['POST'])
def load():
    global th
    global finished
    finished = False
    th = Thread(target=something, args=())
    th.start()
    return render_template('loading.html')


def something():
    """ The worker function """
    global finished
    time.sleep(5)
    finished = True


@app.route('/result')
def result():
    """ Just give back the result of your heavy work """
    return 'Done'


@app.route('/status')
def thread_status():
    """ Return the status of the worker thread """
    return jsonify(dict(status=('finished' if finished else 'running')))


if __name__ == "__main__":
    app.run(debug=True)
Run Code Online (Sandbox Code Playgroud)

所以在你的loading.html 中插入一个循环的 Ajaxget()请求:

<html>
  <head>
    <script src="https://ajax.googleapis.com/ajax/libs/jquery/1.11.0/jquery.min.js"></script>
    <script>
      $(document).ready(function() {
        var refresh_id = setInterval(function() {
            $.get(
              "{{ url_for('thread_status') }}",
              function(data) {
                console.log(data);
                if (data.status == 'finished') {
                  window.location.replace("{{ url_for('result') }}");
                }
              }
            )}
          , 1000);
      });
    </script>
  </head>
  <body>
    <p>Loading...</p>
  </body>
</html>
Run Code Online (Sandbox Code Playgroud)

如果您愿意,您甚至可以通过进度计数器附加它。但是您需要注意防止线程多次运行。