一、环境搭建与依赖安装
1. 安装依赖包
pip install celery redis eventlet
celery
:异步任务队列框架。redis
:作为消息中间件(Broker)和结果存储(Backend)。eventlet
:用于 Windows 环境下的协程支持(解决多进程兼容性问题)。
2. 启动 Redis 服务
- 下载 Windows 版本 Redis:
https://github.com/tporadowski/redis/releases
- 启动 Redis 服务:
redis-server.exe redis.windows.conf
二、代码实现
1. 定义 Celery 任务(tasks.py
)
import time
from celery import Celery
# 创建 Celery 实例,指定 Broker(Redis)和结果存储(Redis)
broker = 'redis://127.0.0.1:6379/1'
backend = 'redis://127.0.0.1:6379/2'
app = Celery(
'tasks',
broker