我正在使用pika和托管的CloudAMQP示例。
正在以短脉冲将消息发布到队列：~10条消息/秒，然后几分钟内什么都没有。消费者有时可能需要长达~30秒的时间来处理一条消息。我的简单消费者代码是：

import pika, os, time

url = os.environ.get('CLOUDAMQP_URL')
params = pika.URLParameters(url)
connection = pika.BlockingConnection(params)
channel = connection.channel()

def callback(ch, method, properties, body):
  print("Received " + str(body), method, properties)
  # ... long task that is equivalent to:
  time.sleep(30)

queue_name = 'test-queue'

channel.queue_declare(queue=queue_name, durable=True, exclusive=False, auto_delete=False)

channel.basic_consume(queue_name, callback, auto_ack=True)

channel.start_consuming()
connection.close()

有时，我会看到以下行为：

• 在几次快速爆发中向队列发布了约20-30条消息
• 消费者获取所有排队的消息，一次自动确认它们，即它们都从队列中“消失”
• 在处理自动确认的消息后，Pika将引发以下异常：

pika.exceptions.StreamLostError: Stream connection lost: RxEndOfFile(-1, 'End of input stream (EOF)')

(full追溯如下）
我通过禁用auto_ack=True和手动确认消息来解决我的问题（见下文）。
是否有其他方法可以解决这个问题？EOF异常的发生是因为CloudAMQP/RabbitMQ服务器没有及时得到心跳，并关闭了连接？还是因为pika的内部超时？谢谢！
追溯：

Traceback (most recent call last):
 File "/app/app.py", line 146, in <module>
   pika_obj['pika_channel'].start_consuming()
 File "/app/.heroku/python/lib/python3.9/site-packages/pika/adapters/blocking_connection.py", line 1866, in start_consuming
   self._process_data_events(time_limit=None)
 File "/app/.heroku/python/lib/python3.9/site-packages/pika/adapters/blocking_connection.py", line 2027, in _process_data_events
   self.connection.process_data_events(time_limit=time_limit)
 File "/app/.heroku/python/lib/python3.9/site-packages/pika/adapters/blocking_connection.py", line 825, in process_data_events
   self._flush_output(common_terminator)
 File "/app/.heroku/python/lib/python3.9/site-packages/pika/adapters/blocking_connection.py", line 522, in _flush_output
   raise self._closed_result.value.error
pika.exceptions.StreamLostError: Stream connection lost: RxEndOfFile(-1, 'End of input stream (EOF)')