文章/答案/技术大牛

发布

问阻塞获取aio_pika
EN

Stack Overflow用户

提问于 2018-06-07 09:59:49

回答 1查看 320关注 0票数 4

我本以为

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)

发布于 2018-06-07 13:43:45

RabbitMQ团队监视邮寄名单，有时只回答StackOverflow上的问题。

根据该方法的文档，您应该使用非常长的超时时间。似乎没有其他方法可以做到这一点。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/50738383

复制

相似问题

问阻塞获取aio_pikaEN