Вопрос про rabbit и pika Можно ли вообще настроить получение консумером

Question

Вопрос про rabbit и pika Можно ли вообще настроить получение консумером

только тех сообщений, что он получил в реальном времени?
Сейчас продусер отправляет сообщения в очередь, потом подключаюсь консумером и он все эти сообщения выводит (ну типа гарантированная доставка) - а вот старые сообщения не нужны.
Или как вообще эту задачу реализовывать?

#backend #programming #python #russian

0

12.07.2022

2 ответов

21 просмотр

Lex Автор вопроса

Kirill Kuzminykh
Очереди может создавать консьюмер. Причём он может...

Старые сообщения вообще не нужны, только те, что были отправлены после подключения. Expiration поставил "10" - работает как нужно, видимо это в мсек. У меня планируется до 1800 exchange, они отправляют сообщения по мере появления, а вот уже на уровне получения будут появляться очереди. Хватит же мне решения с expiration? Просто первый вариант не совсем понял, и лучше ли он для меня будет

0

12.07.2022

Kirill Kuzminykh · Accepted Answer

Очереди может создавать консьюмер. Причём он может создавать их эксклюзивными, так что бы очередь умирала вместе с ним самим. А пока у exchange-а нет очередей, то ему некуда будет пихать сообщения и они будут "пропадать". Как только консьюмер подключится и прибиндит свою очередь к exchang-у, только тогда в эту очередь начнут поступать сообщения. Ну или выше про ttl писали, но оно может несколько по другому сработать. Если в очереди накопится много задач, то консьюмер может успеть выхватить самые первые (самые старые) и пока он обрабатывает их какое-то время, остальные задачи в очереди (более новые) протухнут.

170 похожих чатов

Вопрос про rabbit и pika Можно ли вообще настроить получение консумером

2 ответов

Похожие вопросы