aio pika 等待消息确认到rabbitmq时出现超时异常

Question

我正在使用 aio pika 版本 6.7.1 和 python 3.7.7 以及rabbitmq 3.8.9。

消费者看起来像文档建议：

        async with connection:
            # Creating channel
            channel = await connection.channel()
            await channel.set_qos(prefetch_count=self.prefetch_count)

            # Declaring exchange
            exchange = await channel.declare_exchange(
                'EX', ExchangeType.TOPIC, durable=True
            )

            # Declaring queue
            queue = await channel.declare_queue(self.queue_name, durable=True)

            # Bind queue to exchange
            await queue.bind(exchange)
            async with queue.iterator() as iter:
               async for message in iter:
                    try:
                       await self.do_stuff_to_message(message)
                       await message.ack()
                    except Exception as e:
                       await self.processor.handle_failure(e, message)

但是收到“asyncio.TimeoutError from None”错误 - 它只能通过从 message.ack() 中删除等待来解决。

原因是什么以及正确的使用方法是什么？