在 Windows 上运行 celery - Python

Celery 是一个独立的分布式任务队列，它可以和 Python 应用程序或者其他任意语言编写的应用进行交互。下面介绍如何在 Windows 系统上运行 celery。

第步步骤

1. 安装 RabbitMQ

Celery 使用 RabbitMQ 作为消息代理来传递消息。 所以第一步是安装 RabbitMQ，可以通过以下网址下载安装包：https://www.rabbitmq.com/download.html

安装完RabbitMQ后, 启动服务：

.\rabbitmq-server.bat start

2. 安装 Celery

可以通过 pip 来安装 Celery：

pip install celery

3. 创建 Celery 任务

我们可以在 Python 应用程序中创建 Celery 任务：

from celery import Celery

app = Celery('tasks', broker='pyamqp://guest@localhost//')

@app.task
def add(x, y):
    return x + y

4. 运行 Celery

如果安装好和配置好了 celery，可以通过以下方式启动 celery：

celery -A tasks worker --loglevel=INFO

5. 调用 Celery 任务

Celery 任务已经创建好了，现在我们可以通过以下代码来调用它：

from tasks import add

result = add.delay(4, 4)
print(result.get())

结论

现在，我们已经成功在 Windows 系统上运行了 Celery，并且使用了 RabbitMQ 作为消息代理来传递 Celery 任务的消息。