在Flask运行后台Celery任务

Question

问题已更新，包括取得的进展

我有下面的代码，我的芹菜任务开始得很好，我只是不知道我应该把异步结果存储在哪里，这样我以后可以再次查看

#!/usr/bin/env python
"""Page views."""
from flask import render_template, request
from flask import Flask
from celerytest import add
from time import sleep

app = Flask(__name__)
async_res = []
@app.route('/', methods=['GET', 'POST'])
def run():
    if request.method == 'GET':
        return render_template("template.html")
    else:
        form = request.form
        n1 = str(form.get("n1"))
        n2 = str(form.get("n2"))
        aysnc_res = add.delay(n1,n2)
        return render_template("loading.html")
@app.route('/loading')
def check_if_complete():
    if async_res.ready() == True:
        return render_template("template2.html", val=async_res.get())
    else:
        sleep(5)
        return render_template("loading.html")

if __name__ == '__main__':
    app.run()

似乎在我的flask应用程序中将async_res存储为全局变量会导致服务器错误。那么，存储结果的最佳方法是什么，这样我就可以在我的"加载页面"

Answer 1

我最终能够将任务的ID保存在Flask 的会话字典中

参见以下代码：

#!/usr/bin/env python
"""Page views."""
from flask import render_template, request
from flask import Flask
from celerytest import add
from time import sleep

app = Flask(__name__)
@app.route('/', methods=['GET', 'POST'])
def run():
    if request.method == 'GET':
        return render_template("template.html")
    else:
        form = request.form
        n1 = str(form.get("n1"))
        n2 = str(form.get("n2"))
        aysnc_res = add.delay(n1,n2)
        session['TASK_ID'] = async_res.id
        return render_template("loading.html")
@app.route('/loading')
def check_if_complete():
    aysnc_res = session['TASK_ID']
    if async_res.ready() == True:
        return render_template("template2.html", val=async_res.get())
    else:
        sleep(5)
        return render_template("loading.html")

if __name__ == '__main__':
    app.run()