Как использовать поток RabbitMQ, начиная с последнего сообщения в потоке? ⇐ Python
-
Anonymous
Как использовать поток RabbitMQ, начиная с последнего сообщения в потоке?
Я хотел бы реализовать что-то с поведением, аналогичным «Сохраненному сообщению» MQTT. IE. Я хочу прикрепить потребителя и сразу начать читать с самого последнего отправленного сообщения. Похоже, Rabbitmq Streams должен дать мне то, что я ищу.
Я немного застрял, потому что можно установить смещение last (см. здесь), которое начинает чтение с последнего блока сообщений. Но я ищу последнее сообщение.
То есть: я не вижу, как определить, какое сообщение в данный момент находится в блоке последним, когда я подписываюсь.
Есть ли способ установить смещение к последнему сообщению в потоке?
Я хотел бы реализовать что-то с поведением, аналогичным «Сохраненному сообщению» MQTT. IE. Я хочу прикрепить потребителя и сразу начать читать с самого последнего отправленного сообщения. Похоже, Rabbitmq Streams должен дать мне то, что я ищу.
Я немного застрял, потому что можно установить смещение last (см. здесь), которое начинает чтение с последнего блока сообщений. Но я ищу последнее сообщение.
То есть: я не вижу, как определить, какое сообщение в данный момент находится в блоке последним, когда я подписываюсь.
Есть ли способ установить смещение к последнему сообщению в потоке?
