不能直接在Flask路由中执行耗时任务，因其单线程同步模型会导致请求阻塞、超时、资源独占及任务丢失；必须解耦至Celery+RabbitMQ异步处理。
为什么不能直接在Flask路由里跑耗时任务
用户发个请求，后端卡住几秒甚至几十秒，浏览器就转圈或超时，504 Gateway Timeout 或 Connection reset 都可能冒出来。Flask 的默认 Werkzeug 开发服务器是单线程同步模型，生产环境用 Gunicorn/Uvicorn 也顶多靠多 worker 抢并发，但每个请求仍会独占一个 worker 进程/线程——任务不结束，这个资源就一直被锁着，无法响应新请求。
更麻烦的是：一旦进程崩溃或重启，正在跑的耗时任务就直接丢了，没日志、没重试、没状态追踪。
所以必须把耗时逻辑从 HTTP 请求生命周期里摘出来，交给独立进程管理。
Celery + RabbitMQ 的最小可行组合怎么搭
Celery 是任务调度框架，RabbitMQ 是消息代理（broker），两者配合才能实现“发任务 → 存队列 → 消费执行”的解耦链路。别用 Redis 当 broker 来练手——它默认不持久化队列和消息，服务一重启任务全丢；RabbitMQ 的 durable 队列 + delivery_mode=2 才真能扛住宕机。
实操要点：
让 macOS 自动化像说话一样简单 —— 用代码控制你的 Mac，无需学习 AppleScript 系统要求 macOS 14+ (Sonoma) Python 3.9+ 需要开启：辅助功能 + 屏幕录制权限
- 安装：
pip install celery+docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management（开启管理界面） - Celery 实例初始化要显式指定 broker URL：
Celery('myapp', broker='amqp://guest:guest@localhost:5672//')，末尾双斜杠表示默认 vhost - 任务函数必须用
@celery.task装饰，且不能定义在 Flask 的app.route函数内部——否则无法被 worker 进程 import - 启动 worker 要单独开终端：
celery -A tasks.celery_app worker --loglevel=info，其中tasks.py是放任务函数的模块，celery_app是 Celery 实例变量名
Flask 怎么安全地触发并追踪 Celery 任务
别在视图里直接调 my_task.delay() 就完事。用户需要知道“任务发出去没？执行到哪了？成功还是失败？”，而 Celery 默认只返回一个 AsyncResult 对象，里面只有 id 和基础状态（PENDING/STARTED/SUCCESS/FAILURE）。
关键补丁：
- 启用结果后端：在 Celery 初始化时加
backend='rpc://'（轻量，适合小规模）或backend='redis://localhost:6379/0'（推荐，支持历史查询） - 任务函数里别 return 大对象（比如整个 pandas DataFrame），序列化会炸；改用存文件路径或数据库 ID，再让前端按需查
- 前端轮询用
/task-status/接口，视图里调celery_app.AsyncResult(task_id).state和.result（失败时是异常对象，要 try/catch） - 加个超时兜底：
celery_app.AsyncResult(task_id).get(timeout=30)，避免前端无限等
本地开发时 RabbitMQ 连不上或任务不执行的常见硬伤
90% 的“Celery 不干活”问题出在环境错位，不是代码写错：
- RabbitMQ 容器启动后没等 10 秒就急着起 worker——用
docker logs rabbitmq看是否输出Ready，没看到就别急着连 - worker 启动命令里的
-A模块路径错了，比如写成celery_app而不是tasks.celery_app，报错是ImportError: No module named 'celery_app' - Flask 视图和 Celery 任务用了同一个数据库连接对象（比如全局
db），worker 进程里没初始化连接池，一执行就卡在OperationalError: (psycopg2.OperationalError) server closed the connection unexpectedly - 忘记在任务函数里加
bind=True却又用了self.retry()，结果报AttributeError: 'NoneType' object has no attribute 'retry'
最易忽略的一点：Celery worker 默认不自动重载代码。改了任务函数，必须手动 kill 再 restart worker，不然永远在跑旧逻辑。
Python免费学习笔记（深入）：立即使用
在学习笔记中，你将探索 Python 的核心概念和高级技巧！
