Celery/Flask中update_state无法更新任务状态问题求助

你遇到的核心问题是任务状态无法更新、元数据获取失败，主要由配置混乱、状态查询时机错误等原因导致，具体修复方案如下：

1. 清理冗余配置，统一规则 #

你的配置同时存在带CELERY_前缀和不带前缀的项，会导致Celery配置解析混乱。Celery 4.x及以后版本与Flask集成时，统一使用CELERY_前缀的配置即可，无需额外配置CACHE_BACKEND（CELERY_RESULT_BACKEND已负责存储任务状态与结果）：

# Flask配置文件中保留以下内容即可
CELERY_BROKER_URL = "redis://127.0.0.1:6379/0"
CELERY_RESULT_BACKEND = "redis://127.0.0.1:6379/0"

2. 修正任务状态更新的参数写法 #

Celery内置状态（如RUNNING）为大写格式，且update_state建议明确参数名避免歧义。同时确保导入正确的sleep方法：

from time import sleep
from flask import current_app

@celery.task(bind=True, name="apptask")
def apptask(self, oi):
    for x in range(40):
        sleep(1)
        # 明确指定state参数，用大写内置状态，同时在meta中加入进度标识
        self.update_state(state="RUNNING", meta={"test": 1, "val": oi, "progress": x+1})
    return current_app.name

3. 调整状态查询的时机与方式 #

你在调用任务后立即查询状态，此时任务大概率还处于PENDING等待状态，自然看不到中间更新。正确的做法是返回任务ID，通过单独的路由轮询查询状态：

@users.route("/test", methods=["GET"])
def test():
    task = apptask.apply_async(args=["d"])
    # 返回任务ID，让前端/客户端后续查询状态
    return {"task_id": task.id}, 202

# 添加专门的任务状态查询路由
@users.route("/task-status/<task_id>", methods=["GET"])
def task_status(task_id):
    task = apptask.AsyncResult(task_id)
    if task.state == "PENDING":
        response = {"state": task.state, "status": "任务等待执行中..."}
    elif task.state != "FAILURE":
        # 区分元数据和最终返回结果
        response = {
            "state": task.state,
            "data": task.info.get("val") if isinstance(task.info, dict) else task.info,
            "progress": task.info.get("progress", 0) if isinstance(task.info, dict) else 100
        }
    else:
        # 任务失败时返回错误信息
        response = {"state": task.state, "error": str(task.info)}
    return response

4. 确保Celery与Flask应用正确绑定 #

如果是手动初始化Celery，必须让Celery加载Flask的配置，否则结果后端配置不会生效：

from celery import Celery

def make_celery(app):
    celery = Celery(app.import_name, broker=app.config['CELERY_BROKER_URL'])
    # 同步Flask的所有配置到Celery
    celery.conf.update(app.config)
    return celery

# 初始化Celery实例
celery = make_celery(app)

5. 验证Redis存储状态 #

可以通过Redis客户端执行KEYS "*celery-task-meta-*"命令，查看是否生成了任务元数据的key。如果没有，说明Celery未正确连接到Redis结果后端，需检查Redis服务状态或配置路径。

内容的提问来源于stack exchange，提问作者Lewis Morris