У меня есть исключение RabbitMQ pika.exceptions.ConnectionClosed, появляющееся время от времени, и...

Я хотел бы знать, является ли это правильным способом управления очередями auto_delete в разных...

У меня есть док-контейнер, который запускает скрипт на python. Скрипт снабжен URL-адресом AMQP,...

Я хочу, чтобы мой pub / sub сохранял только последнее доступное сообщение на канале и сбрасывал все...

Обычно драйвером pika, когда мы устанавливаем потребителя, мы должны передать обратный вызов в...

Я знаю, что мы можем сделать это, чтобы вывести очередь в rabbitmq. rabbitmqctl list_queues но как...

После Пример получения Pika , я бы хотел, чтобы клиент обрабатывал больше одновременных запросов.У...

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

Я хочу обрабатывать сообщения в нескольких потоках, но я получаю ошибку во время выполнения этого...

У меня есть несколько сценариев, использующих pika.SelectConnection для связи с сервером RabbitMq....

Согласно документации Pika"брокер RabbitMQ использует TCP Backpressure для замедления вашего...

У меня есть очередь, и т. Д .: online_queue = self._channel.queue_declare( durable = True, queue =...

Мне нужно уметь изящно останавливать потребителя (работника), который работает в ioloop Пика

Я ищу реализацию очереди приоритетов с RabbitMQ. Список рассылки рекомендует использовать несколько...

Модуль продюсера моего приложения запускается пользователями, которые хотят отправить работу на...

Кажется, чем дольше я работаю на своем сервере rabbitmq, тем больше у меня проблем с...

Я пытаюсь настроить рабочий демон для обработки сообщений от rabbitmq.Я использую Пика и его...

Я бы хотел сделать магию маршрутизации с AMQP. Моя установка - это Python с Pika на стороне...

Я пытаюсь написать приложение на Python, которое использует RabbitMQ с помощью библиотеки Pika . Я...