pika

4зной

2ответ

Не удалось установить Pika используя пункт установить

Получение следующих после запуска: pip install pika (я замкнута исключение в первой строке в трассировке и последней строки) Collecting Pika using cahced pika-0.10.0-py2.py3-none-any.whl Install

0зной

1ответ

Пика - RabbitMQ, используя Basic.get для cosume одного сообщения из очереди

Я использую метод, описанный here так: while method_frame is None: method_frame, header_frame, method_frame= channel.basic.get("test_queue) Это выглядит следующим образом опрос не является настолько э

0зной

3ответ

Бесконечная цикл сообщений: То же сообщение повторно доставлен в питоной RabbitMQ потребителе

Я использую пример потребитель размещена здесь: http://pika.readthedocs.org/en/latest/examples/asynchronous_consumer_example.html Причиной я использую ExampleConsumer была моя связь с RabbitMQ терпела

0зной

1ответ

Передача сообщений только один раз в заголовках заголовков RabbitMQ

Я пытаюсь реализовать систему распределения задач с помощью RabbitMQ. Я начал с чего-то вроде кода из этой статьи: http://deontologician.tumblr.com/post/19741542377/using-pika-to-create-headers-exchan

2зной

1ответ

rabbitmq несколько потребителей в очереди - только один получает сообщение

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

1зной

1ответ

Pika BlockingConnection & RabbitMQ: соединение закрыто

У меня есть 2 rabbitmq в кластерной нагрузке, сбалансированный базовым балансиром нагрузки Azure. Клиент подключается к LB с BlockingConnection. Когда есть сообщение, обмениваемое клиентами, все работ

2зной

1ответ

Pika channel.stop_consuming не останавливает цикл start_consuming

У меня есть эта часть кода, в основном она запускается channel.start_consuming(). Я хочу, чтобы он остановился через некоторое время. Я думаю, что channel.stop_consuming() правильный метод: def stop_c