rabbitmq 阻止获取aio_pika

vom3gejh  于 2023-10-20  发布在  RabbitMQ
关注(0)|答案(1)|浏览(128)

我预期

await queue.get()

在aio_pika中设置了一个阻塞,但是即使我没有设置timeout参数,我也会立即得到一个错误:
aio_pika.exceptions.空
无论如何,在aio_pika中获得一个阻塞?
编辑:这是迄今为止我能想到的最好的。

while True:
        msg = await q.get(fail=False)
        if msg:
            break
        await asyncio.sleep(1)
sqougxex

sqougxex1#

根据该方法的文档,您应该使用很长的超时。似乎没有别的办法了。

相关问题