В Pika или RabbitMQ, как я могу проверить, потребляют ли какие-либо потребители в настоящее время?

Я хотел бы проверить, еслиПотребитель / работник присутствует, чтобы потреблятьСообщение Я собираюсь отправить.Если нетт любойработникЯ бы начал несколько ра...

RabbitMQ, Пика и стратегия переподключения

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

RabbitMQ изменяет параметры очереди в производственной системе

Я использую RabbitMQ в качестве очереди сообщений в сервис-ориентированной архитектуре, где многие отдельные веб-службы публикуют сообщения, связанные с очер...

RabbitMQ pika.exceptions.ConnectionClosed

Я пытался отправить сообщение и получить сообщение, используя RabbitMQ. У меня нет опыта работы в информатике, термины, которые я использовал, не могли быть ...

SparkStreaming, RabbitMQ и MQTT в Python с использованием Пика

Просто чтобы усложнить задачу, я бы хотел получать сообщения из очереди rabbitMQ. Теперь я знаю, что есть плагин для MQTT на кролика (https://www.rabbitmq.co...

Pika blocking_connection.py случайный тайм-аут подключения к RabbitMQ

@JebaseelanRavi, не могли бы вы опубликовать полный трекбек на своего рода пастбине или открыть новый вопрос и вставить его туда? Я никогда не видел эту ошибку раньше :)

ользую scrapy для получения сообщения (url) из RabbitMQ, но когда я использую yield для вызова метода parse, передавая мой url в качестве параметров. Программа не входит в метод обратного вызова. Ниже приведен следующий код моего паук # -*- ...

Как создать отложенную очередь в RabbitMQ?

Какой самый простой способ создать очередь задержки (или парковки) с помощью Python, Pika и RabbitMQ? Я видел подобноевопросы, но не для Python.Я нахожу это ...

Ошибка «неизвестный тег доставки» возникает при попытке подтверждения сообщений в RabbitMQ с использованием pika (python)

Я хочу обрабатывать сообщения в несколько потоков, но я получаю ошибку во время выполнения этого кода: from __future__ import with_statement import pika import sys from pika.adapters.blocking_connection import BlockingConnection from pika ...

Как сделать простую Pika SelectConnection для отправки сообщения, в python?

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