17370845950

Celery异步任务核心是消息发送、任务执行与结果处理；需先启动RabbitMQ作为broker，Celery通过pyamqp连接字符串明确指定地址，任务用.delay()触发，Worker进程必须持续运行消费队列。

用 Celery 和 RabbitMQ 做 Python 异步任务，核心就三点：消息能发出去、任务能跑起来、结果可查或可忽略。不靠黑盒配置，关键在理解每个组件的角色和连接逻辑。

RabbitMQ 要先跑起来，别跳过这步

RabbitMQ 是消息中转站（broker），Celery 任务得靠它传话。没启动 RabbitMQ，Celery 就像发不出去的短信——生产者以为发了，其实卡在本地。

• macOS 上用 brew install rabbitmq 安装后，执行 rabbitmq-server 启动服务
• Linux 可用 sudo systemctl start rabbitmq-server
• 验证是否成功：浏览器打开 http://localhost:15672，默认账号密码都是 guest
• 如果打不开，检查 Erlang 是否已安装（RabbitMQ 依赖 Erlang 运行环境）

Celery 实例要明确绑定 RabbitMQ 地址

Celery 不自带消息通道，必须显式告诉它“Broker 在哪”。常见错误是只写 pyamqp:// 却漏掉用户、密码、host 或端口。

• 标准连接字符串格式：pyamqp://guest:guest@localhost:5672//
• 在 Celery 应用初始化时设置：app = Celery('tasks', broker='pyamqp://guest:guest@localhost:5672//')
• 若改用 vhost（比如 /myvhost），记得 URL 末尾双斜杠前加 vhost 名：pyamqp://guest:guest@localhost:5672/myvhost

任务定义与触发要分清“声明”和“执行”

@task 装饰器只是注册任务，调用 .delay() 或 .apply_async() 才真正把消息推到 RabbitMQ 队列里。

• 定义任务示例：@app.task def send_email(to, subject): ...
• 触发异步执行：send_email.delay('user@example.com', 'Welcome')
• 不要在 Web 请求中直接调用 send_email()（同步执行），否则仍会阻塞响应
• 如需获取返回值，启用 result backend（如 Redis），并用 .get(timeout=10) 等待结果

Worker 进程必须持续运行才能消费任务

Celery Worker 是后台“打工人”，它主动连接 RabbitMQ，拉取队列里的任务并执行。关掉终端或没起 worker，任务就永远躺在队列里不动。

• 启动命令：celery -A tasks worker --loglevel=info（假设任务模块叫 tasks.py）
• 推荐加 --concurrency=4 控制并发数，避免单机压垮资源
• 开发时可用 --pool=solo 简化调试（单线程模式，方便断点）
• 生产环境建议用 systemd 或 supervisor 管理 worker 生命周期