python集成rabbitmq fastapi 异步消费消息

要在Python中集成RabbitMQ和FastAPI来实现异步消费消息，可以使用aio_pika库。

首先需要安装aio_pika和FastAPI：

pip install aio_pika fastapi

然后可以使用以下代码作为示例：

from fastapi import FastAPI
import aio_pika

app = FastAPI()

@app.on_event("startup")
async def startup():
    # 连接RabbitMQ
    connection = await aio_pika.connect_robust("amqp://guest:guest@localhost/")
    app.state.rabbitmq = connection

@app.on_event("shutdown")
async def shutdown():
    # 关闭RabbitMQ连接
    await app.state.rabbitmq.close()

@app.get("/")
async def read_root():
    # 创建一个channel
    channel = await app.state.rabbitmq.channel()

    # 声明一个queue
    queue = await channel.declare_queue("my_queue")

    # 异步获取消息
    async with queue.iterator() as queue_iter:
        async for message in queue_iter:
            async with message.process():
                print(message.body)

    return {"status": "ok"}

在上面的示例中，我们在FastAPI的startup事件中连接到RabbitMQ，并将连接保存在app.state.rabbitmq中。在shutdown事件中关闭连接。

在read_root函数中，我们创建一个channel并声明一个queue。然后使用queue.iterator()方法获取一个异步迭代器，并使用async for循环异步获取消息。在异步获取到消息后，我们使用message.process()方法来确认消息已经被处理。

当然，在实际应用中，你可能需要根据具体的业务场景来编写更加复杂的代码。不过，以上代码可以作为一个很好的起点来帮助你快速集成RabbitMQ和FastAPI。