celery 连接 rabbitmq

使用Python的celery库连接到RabbitMQ，需要进行以下步骤：

1. 安装celery和pika库

pip install celery pika

2. 创建一个celery实例

from celery import Celery

app = Celery('myapp', broker='amqp://guest:guest@localhost//')

其中，`broker`参数指定RabbitMQ的连接地址，格式为`amqp://user:password@host:port//`。

3. 定义任务

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

4. 启动worker进程

celery -A myapp worker --loglevel=info

其中，`-A`参数指定celery实例的名称，`--loglevel`参数指定日志级别。

5. 调用任务

result = add.delay(1, 2)
print(result.get())

其中，`delay`方法异步调用任务，返回一个AsyncResult对象，可以通过`get`方法获取任务的结果。

以上是使用celery连接RabbitMQ的基本流程，可以根据需要进行配置和定制化。