Имам настроен RabbitMQ сървър , където извличам съобщения чрез Python-Pika . Проблемът е, че ако имам постоянен режим на доставка е активиран и работниците не успяват да обработят съобщение. Вместо да пусне съобщението, то ще го запази до...

Имам две отделни копия на RabbitMQ. Опитвам се да намеря най-добрия начин да слушам събития и от двете. Например, мога да консумирам събития на едно със следното: credentials = pika.PlainCredentials(user, pass) connection =...

В момента работя с RabbitMQ в Python, използвайки клиента Pika, за да създам сървър, който обработва различни типове съобщения. Основната настройка, която имам, е една опашка, която получава всички входящи съобщения, процес на маршрутизиране, който...

Нов съм в използването на RabbitMQ и Pika, така че моля да ме извините, ако отговорът е очевиден... Подаваме някои данни и предаваме резултатите в нашата опашка със съобщения rabbitmq. Опашката се консумира от процес, който записва данните в...

Работя върху това да накарам някои разпределени задачи да работят чрез RabbitMQ. Прекарах известно време, опитвайки се да накарам Celery да направи това, което исках, и не можах да го накарам да работи. След това се опитах да използвам Pika и...