如何使用Flask-Celery app向用户报告状态更新？

from flask import Flask
from flask_celery import make_celery

app = Flask(__name__)
app.config['CELERY_BROKER_URL'] = 'redis://localhost:6379/0'
app.config['CELERY_RESULT_BACKEND'] = 'redis://localhost:6379/0'

celery = make_celery(app)

@celery.task
def update_status(user_id):
    # 执行一些耗时的操作
    # 更新任务状态
    # 返回结果
    return result

from celery.result import AsyncResult

@app.route('/status/<task_id>')
def get_status(task_id):
    task = AsyncResult(task_id, app=celery)
    if task.state == 'PENDING':
        response = {
            'status': 'pending',
            'message': 'Task is still running...'
        }
    elif task.state == 'SUCCESS':
        response = {
            'status': 'success',
            'message': 'Task completed successfully.',
            'result': task.result
        }
    else:
        response = {
            'status': 'failure',
            'message': 'Task failed.'
        }
    return jsonify(response)

@app.route('/process')
def process():
    task = update_status.delay(user_id)
    return jsonify({'task_id': task.id})