celery rabbitmq 配置 broker和backend

在使用Celery和RabbitMQ作为消息代理和结果后端时，你需要正确配置Celery以便它们可以有效地通信。以下是如何配置Celery以使用RabbitMQ作为broker（消息代理）和backend（结果后端）的步骤：

1. 安装必要的库
   首先，确保你已经安装了Celery和pika（用于RabbitMQ的库）。如果还没有安装，你可以通过pip安装它们：

pip install celery[librabbitmq]

2. 配置Celery
   在你的Python项目中，你需要设置Celery应用并配置它使用RabbitMQ。通常，你会在项目的初始化文件（如celery.py）中完成这些设置。

示例配置文件 (celery.py)

from celery import Celery

创建Celery应用实例

app = Celery('my_project',broker='amqp://username:password@localhost:5672//',backend='rpc://')

自动从当前模块中发现task模块（如果有）

app.autodiscover_tasks(['my_project.tasks'])

3. 配置RabbitMQ Broker
   在上面的配置中，broker参数指定了RabbitMQ服务器的连接信息。格式为：

amqp://username:password@hostname:port/vhost
username：你的RabbitMQ用户名。password：你的RabbitMQ密码。hostname：RabbitMQ服务器的主机名或IP地址（例如localhost）。port：RabbitMQ的端口号（默认是5672）。vhost：虚拟主机名（如果你使用的是默认虚拟主机，可以省略或使用/）。

4. 配置Backend（可选）
   对于结果后端，你可以使用RPC后端或者其他后端如Redis。如果你的任务不需要存储结果，可以省略backend配置。如果你想要使用RPC后端，可以像下面这样配置：

backend='rpc://'

或者，如果你想使用Redis作为结果后端，可以这样配置：

backend='redis://:password@localhost:6379/0'

5. 启动RabbitMQ服务器
   确保你的RabbitMQ服务器正在运行。如果你使用的是本地安装的RabbitMQ，可以通过以下命令启动：

rabbitmq-server

6. 运行你的Celery worker
   一旦你设置好了配置文件，就可以启动一个或多个Celery worker来处理任务了。使用以下命令启动worker：

celery -A my_project.celery worker --loglevel=info

这里，my_project.celery是包含你的Celery实例的模块路径。

7. 测试配置
   最后，确保一切配置正确，可以通过发送一个简单的任务到Celery并检查RabbitMQ是否正确接收到消息来测试。例如，在tasks.py中定义一个简单的任务：

from my_project.celery import [e-mail]
def add(x, y):return x + y

然后，在你的代码中调用这个任务：

result = add.delay(4, 4)
print(result.get(timeout=1))  # 输出结果8

通过以上步骤，你应该能够成功配置并使用Celery和RabbitMQ。