Всем привет, подскажите, пожалуйста, сколько живет connection к рэббиту, могу ли я использовать один инстанс подключения? Если да, то считается ли это хорошей практикой? Вот п...
pika.exceptions.ChannelClosedByBroker: (406, "PRECONDITION_FAILED - inequivalent arg 'x-message-ttl' for queue 'amo-crm.q' in vhost '/': received the value '60000' of type 'si...
https://habr.com/ru/companies/domclick/articles/500978/ Добрый день, подскажите, пожалуйста, насколько хорошая практика сделать вот такую структуру эксчейнджей и очередей для...
Всем привет, подскажите, пожалуйста, что произойдёт при вызове метода queue_declare с одним и тем же именем очереди, но с разными остальными параметрами? Создастся ли новая оч...
Опустить их контейнеры недостаточно, да?:
Привет, подскажите, как я могу отправить через кафку словарь по типу {"id": 0, "file": file}, где file это объект werzeug.datastructures.FileStorage, ну то есть файл, полученн...
Реально ли сделать reject в консюминге так, чтобы сообщение вернулось в очередь измененным? Изменить какой-нибудь параметр в json, допустим. Или же лучше делать ack, и паблиши...
Подскажите, люди добрые, есть Ready Unacked Total сообщения в очереди, как мне все их акнуть? Когда в Get messages rabbit-морды жму на Ack всех сообщений, пропадют только сооб...
По сути, все, что угодно, можно в документации найти, тогда смысл этой группы будет в том, чтобы все отвечали: "омг, иди в доку, лох"?
Ребята, кто-нибудь работал с rabbitmq? Поставьте плюсики, пожалуйста, кто шарит, у кого есть адекватный пример паблишера и консюмера, желательно, чтобы рэббит и консюмер крути...
Есть ли возможность делать выгрузку данных, которые консюмер обработал, средствами rabbitmq?
WARNING:kafka.coordinator:Heartbeat failed for group group because it is rebalancing WARNING:kafka.coordinator.assignors.range:No partition metadata for topic my_topic Один ва...
По хорошему на каждый паблишер и на каждый консюмер создается свой один инстанс BlockingConnection?
У меня консюмер по задумке загружает файл на s3, а из кафки он уйдет сразу же после обработки сообщения, нет?