asynchronous - 阻止获取aio_pika

Question

我预料

await queue.get() 

在 aio_pika 中阻塞，但即使我没有设置超时参数，我也会立即收到错误:

aio_pika.exceptions.QueueEmpty

无论如何要在aio_pika中获得阻塞获取吗？

编辑:这是迄今为止我能想到的最好的。

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

Answer 1

RabbitMQ 团队监控 the rabbitmq-users mailing list并且有时只在 StackOverflow 上回答问题。

<小时/>

根据documentation for that method，您应该使用很长的超时。 。似乎没有其他方法可以做到这一点。