我正在编写一个Flask服务器，它有一个长计算“optimal_portfolio（）”。我希望客户端发送一个请求，在后台开始计算，然后再发送另一个请求，以获得结果。我尝试使用Celery和Redis进行后台计算，但当我尝试访问Celery任务时，我只得到task.status = PENDING。

from portfolio_creator.portfolio_creator import optimal_portfolio
from flask import Flask, request, jsonify
from flask_sqlalchemy import SQLAlchemy
from celery import Celery
import os

app = Flask(__name__)

app.config['CELERY_BROKER_URL'] = os.environ['REDISTOGO_URL']
app.config['CELERY_RESULT_BACKEND'] = os.environ['REDISTOGO_URL']

celery = Celery(app.name, broker=app.config['CELERY_BROKER_URL'])
celery.conf.update(app.config)

@celery.task
def calculate_optimal_portfolio(risk_coefficient):
    return optimal_portfolio(risk_coefficient).to_json(orient="records")

@app.route('/portfolio-creator', methods=['POST'])
def set_portfolio():
    risk_coefficient = request.form.get('risk_coefficient', 5)

    task = calculate_optimal_portfolio.apply_async(
        args=[risk_coefficient])

    return jsonify({"task_id": task.id}), 202

@app.route('/portfolio-creator/<task_id>', methods=['GET'])
def get_portfolio(task_id):
    result = celery.AsyncResult(task_id).result

    if result is None:
        return 'Portfolio not ready.', 404

    return result, 200

if __name__ == '__main__':

    app.run()

字符串
我也试过使用 flask 会话，但这似乎不适合celery 。