Пакетная обработка сообщений от rabbitmq - PullRequest
0 голосов
/ 03 марта 2019

Мне нужно реализовать пакетную загрузку сообщений в базу данных.Я понял, как читать несколько сообщений (предварительная выборка), но не могу понять, как я могу понять, что полученное мной сообщение является последним в очереди и его больше не нужно ожидать (такая ситуация возникает, когдазначение предварительной выборки! = количество сообщений в очереди).

Посоветуйте, пожалуйста, как решить эту проблему.Я использую адаптер SelectConnection из библиотеки pika для подключения к rabbitmq.

...