Я новичок в использовании RabbitMQ и Pika, поэтому извините, если ответ очевиден... Мы загружаем некоторые данные и передаем результаты в нашу очередь сообщений rabbitmq. Очередь используется процессом, который записывает данные в elasticsearch....

У меня есть RabbitMQ Server , на котором я получаю сообщения, используя Python-Pika . Проблема в том, что если у меня есть режим постоянной доставки включен, и рабочие процессы не могут обработать сообщение. Вместо выпуска сообщения он будет...

Я работал над тем, чтобы некоторые распределенные задачи работали через RabbitMQ. Я потратил некоторое время, пытаясь заставить Celery делать то, что я хотел, и не мог заставить его работать. Затем я попытался использовать Pika, и все...

У меня есть два отдельных экземпляра RabbitMQ. Я пытаюсь найти лучший способ прослушивания событий от обоих. Например, я могу использовать события на одном со следующим: credentials = pika.PlainCredentials(user, pass) connection =...

В настоящее время я работаю с RabbitMQ в Python, используя клиент Pika для создания сервера, который обрабатывает различные типы сообщений. Базовая установка, которую я имею, — это одна очередь, получающая все входящие сообщения, процесс...

Я пытаюсь подключиться к своему удаленному rabbitmq с помощью pika, но получаю сообщение об ошибке Connectionclosed(). Я внес необходимые изменения в rabbit.config для гостевого пользователя, чтобы разрешить все соединения, а также одно и то же...

У меня проблема с подключением из кода Python с помощью pika к докеризованному RabbitMQ. Я использую этот код для подключения к очереди: @retry(wait_exponential_multiplier=1000, wait_exponential_max=10000, stop_max_attempt_number=2) def...

Для автоматизации серверов мы пытаемся разработать инструмент, который может обрабатывать и выполнять множество задач на разных серверах. Мы отправляем задачу и имя хоста сервера в очередь. Затем очередь используется запросчиком, который передает...

У меня есть многопроцессорная и многопоточная система, которая работает с Pika для использования некоторых очередей. Когда система работает с одним процессом с многопоточными потребителями, она работает нормально, но когда она работает с...

Я хочу, чтобы мой pub/sub хранил только последнее доступное сообщение на канале и выгружал все предыдущие, которые не были бы использованы из-за того, что потребитель слишком медленный (или приостановлен). ZMQ имеет параметр CONFLATE , но есть ли у...

Я пытаюсь подключиться к удаленному экземпляру rabbitmq, используя SSL. Я решил использовать модуль pika, так как он кажется наиболее широко используемым модулем. У меня есть cacert с удаленного сервера, и я не теряю связь, если нет однорангового...

У меня есть система, которая пишет в RabbitMQ, используя Pika (python). Содержимое представляет собой объект JSON, который включает URL-адрес файла CSV, который требует обработки в фоновом режиме. В другом случае у меня есть клиент NodeJs, который...