我预期
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)
1条答案
按热度按时间sqougxex1#
根据该方法的文档,您应该使用很长的超时。似乎没有别的办法了。