python - 批量处理来自rabbitmq的消息

Question

我需要将消息批量加载到数据库中。我想出了如何阅读几条消息（预取），但我无法弄清楚我如何理解我收到的消息是队列中的最后一条，不再需要预期（这种情况发生在prefetch 的值！= 队列中的消息数）。

请告诉我如何解决这个问题。我使用 pika 库中的 SelectConnection适配器连接到 rabbitmq。

标签： pythonrabbitmqpika