Flask通过ID获取Celery AsyncResult任务状态异常问题排查

核心原因：RPC结果后端的局限性 #

你用的rpc://结果后端是Celery的临时点对点结果存储，它的工作逻辑是：Worker完成任务后，只会把结果返回给发起该任务的原始进程，而且结果不会持久化存储。你的longtask()函数是在一个Flask请求进程里发起任务，而taskstatus()是另一个请求，属于完全不同的进程上下文，所以新进程通过AsyncResult根本查不到之前任务的结果，自然一直显示PENDING。

另外，Windows环境下用eventlet池虽然能正常运行，但偶尔会和RPC后端的通信机制存在兼容性小问题，不过这不是导致当前问题的主要原因。

正确解决步骤 #

1. 更换为持久化结果后端（推荐） #

放弃rpc://，改用支持持久化的后端，这是Web场景下的标准做法，比如Redis或SQLAlchemy：

• 使用Redis：
  1. 安装并启动Redis服务
  2. 安装依赖：pip install redis
  3. 修改Celery配置，将result_backend改为redis://localhost:6379/0
• 使用SQLAlchemy（以SQLite为例，无需额外服务）：
  1. 安装依赖：pip install sqlalchemy
  2. 修改Celery配置，将result_backend改为db+sqlite:///celery_results.db

修改配置后，重启Flask应用和Celery Worker，再测试即可正常获取任务状态与结果。

2. 确保配置完全一致 #

无论使用哪种后端，必须保证Flask应用和Celery Worker的broker_url与result_backend配置完全相同，哪怕是用户名、密码、端口这类细微差异，都会导致无法获取任务结果。

3. 验证Worker启动命令 #

你当前的Worker启动命令celery -A app.celery worker --loglevel=info --pool=eventlet是正确的，只要app.py中的Celery实例确实命名为celery即可。

验证方法 #

修改后端配置后，发起任务并等待完成，调用taskstatus接口，应该能看到state变为SUCCESS，task.info也能返回正确的任务结果。

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