windows celery启动
时间: 2025-01-22 19:08:40 浏览: 61
### 启动 Celery Worker 的准备工作
为了在 Windows 上成功启动 Celery 分布式任务队列,需先确认环境配置无误。确保 Python 和所需依赖已安装完毕,并创建好项目结构。
#### 配置 Celery 应用实例
首先,在项目的根目录下创建 `celery_proj` 文件夹并初始化 Celery 实例:
```python
from celery import Celery
app = Celery(
'celery_proj',
broker='redis://localhost:6379/0', # 使用 Redis 作为消息代理
backend='redis://localhost:6379/1' # 结果存储至另一个 Redis 数据库
)
# 设置默认队列名为 default
app.conf.update(task_default_queue='default')
```
此部分代码展示了如何设置 Celery 应用的基础参数以及指定使用的 Broker 和 Result Backend[^4]。
#### 定义任务文件 tasks.py
在同一目录内新建 `tasks.py` 并编写具体业务逻辑的任务函数:
```python
@app.task(bind=True, name="myCeleryProj.tasks.add")
def add(self, x, y):
"""计算两个数相加"""
return x + y
```
上述例子中定义了一个简单的加法运算任务,并绑定了该方法到 Celery 中。
### 启动 Celery Worker
完成以上步骤之后就可以准备启动 Worker 服务了。打开命令提示符窗口(CMD 或 PowerShell),切换路径至包含 `celery_proj/__init__.py` 文件所在的上级目录,输入如下指令来启动 Worker:
```shell
celery -A celery_proj worker --loglevel=info --pool=eventlet
```
这条命令指明了要加载的应用模块 (`-A`) 及日志级别 (`--loglevel`) ,同时也选择了基于事件驱动的并发池(`eventlet`)[^1]。
注意:如果遇到权限不足或其他错误信息,请尝试以管理员身份重新运行 CMD/Powershell;另外还需保证已经正确安装了 Eventlet 扩展包。
### 测试任务提交功能
最后可以通过调用刚才编写的 `add()` 方法测试整个流程是否正常工作:
```python
>>> result = add.delay(4, 8)
>>> print(result.get())
12
```
这段脚本会向后台提交一个异步请求给 Worker 处理,并等待返回结果。
阅读全文
相关推荐




















