Результаты поиска по запросу "rabbitmq"
RabbitMQ: Как указать очередь для публикации?
RabbitMQ-хChannel#basicConsume Метод дает нам следующие аргументы: channel.basicConsume(queueName, autoAck, consumerTag, noLocal, exclusive, arguments, callback);Дает нам возможность точно сказать RabbitMQ, из какой очереди мы хотим ...
Сбой узла сельдерея, на pidbox уже используется при перезапуске
у меня есть сельдерей, работающий с rabbitmq брокером. Сегодня у меня сбой узла сельдерея - он не выполняет задачи и не отвечает наservice celeryd stop команда. После нескольких повторов узел остановился, но при запуске я получаю ...
Измерение времени выполнения задачи сельдерея
Я преобразовал автономную пакетную работу, чтобы использовать сельдерей для отправки работы, которую нужно сделать. Я использую RabbitMQ. Все работает на одной машине, и никакие другие процессы не используют экземпляр RabbitMQ. Мой скрипт просто ...
Как отключить TCP-порт прослушивания RabbitMQ по умолчанию - 5672
Я настроил RabbitMQrabbitmq.config файл с новым номером порта, то есть 5671 с SSL. Теперь я хочу отключить порт по умолчанию, то есть 5672. Файл конфигурации, как показано ниже: - [ {rabbit, [ {ssl_listeners, [5671]}, ...
Как регистрировать все сообщения Rabbit MQ?
Мы используем сервер RabbitMQ для обмена сообщениями между приложениями. Нам необходимо создать центральный журнал для всех сообщений amqp, поступающих на сервер Rabbit. Нашей целью является не временная отладка, а возможность проверки. В идеале, ...
Группы сообщений в RabbitMQ / AMQP
ActiveMQ / JMS имеет встроенный механизм, гарантирующий, что сообщения с общим заголовком (а именно заголовок JMSXGroupID) всегда потребляются одним и тем же потребителем очереди при использовании шаблона конкурирующих потребителей. Потребители ...
Celery Beat: ограничение до одного экземпляра задачи за раз
У меня есть стебель сельдерея и сельдерей (четыре рабочих), чтобы сделать несколько этапов обработки навалом. Одна из этих задач примерно такая: «для каждого X, для которого не было создано Y, создайте Y». Задача запускается периодически с ...
Динамическое создание очереди с RabbitMQ
Я изучал RabbitMQ для различных топологий, однако я не смог найти никаких ссылок на динамическое создание очереди (так называемое объявление очереди), генерируемое производителем. Идея состоит в том, чтобы создавать очереди динамически в ...
RabbitMQ - сообщение о порядке доставки
Мне нужно выбрать нового брокера очереди для моего нового проекта. На этот раз мне нужна масштабируемая очередь, которая поддерживает pub / sub, и сохранение порядка сообщений является обязательным. Я читаю комментарий Алексис: Он ...
Загрузка конфига rabbitmq при запуске
Как загрузить конфигурацию rabbitmq при запуске, чтобы подтвердить, что объекты-посредники (очереди, обмены, привязки, пользователи, виртуальные хосты, разрешения и параметры) созданы. Согласно документации rabbitmq это можно сделать ...