pika

3зной

2ответ

RabbitMQ пищуха бросает исключение, когда используют учетные данные

Я видел это исключение, когда я тестировал пищуха Это работает, когда я использую только по умолчанию. Однако он исключил, когда я добавил учетные данные в параметры подключения. import pika credenti

rabbitmq pika 2013-08-03

---

2зной

1ответ

RabbitMQ python library check status

Люди, Я пытаюсь проверить соединения, которые выходят из системы, и записывать в журнал, если это произойдет. credentials = pika.PlainCredentials(username, password) parameters = pika.ConnectionParam

python rabbitmq pika python-pika 2013-11-13

---

3зной

2ответ

Использование pika connection.close() дает «ПРЕДУПРЕЖДЕНИЕ: pika.adapters.base_connection: Неизвестное состояние при отключении: 0»

При закрытии соединения с сервером RabbitMQ с помощью pika появляется предупреждение WARNING:pika.adapters.base_connection:Unknown state on disconnect: 0. Если не используется connection.close(), пред

python-2.7 rabbitmq ipython ipython-notebook pika 2014-01-06

---

2зной

1ответ

RabbitMQ: Предотвращение одновременной работы двух разных сотрудников

У меня есть проект Python Django с двумя рабочими RabbitMQ, используя pika lib, который получает задания для выполнения действий над определенным объектом Django, указанным в запросе. Дело в том, что

python django rabbitmq pika 2013-11-20

---

0зной

1ответ

Как указать обмен в Pika потребитель?

Все в названии: в приведенных ниже методах из документации rabbitmq мы видим, что публикация принимает обмен в качестве аргумента, но потребитель этого не делает. Также, когда я нахожусь, queue у потр

rabbitmq pika 2014-01-15

---

0зной

2ответ

Как выглядит подпись метода pika's on_open_error_callback?

Я использую питон и внутри методы класса я self.connection = pika.SelectConnection( self.connectionParameters, on_open_callback=self.onConnected, on_open_error_callback=self.onConn

python pika 2013-10-08

---

0зной

1ответ

публикация и подписка через сервер rabbitmq

Мне нужен сценарий, когда один узел отправляет сообщение, а другой узел начинает ждать сообщения. Каждый узел после получения отправленного сообщения переходит в слушателя, и после получения сообщения

python-2.7 rabbitmq pika python-pika 2014-01-16

---

6зной

2ответ

Как приостановить и возобновить потребление изящно в rabbitmq, pika python

Я использую basic_consume() для получения сообщений и basic_cancel для отмены потребления, но есть проблема. Вот код pika.channel def basic_consume(self, consumer_callback, queue='', no_ack=False,

python rabbitmq pika 2013-12-18

---

4зной

2ответ

RabbitMQ отключить меня через некоторое время

Я пытаюсь постоянно слушать очереди, но примерно через минуту (при условии, моя очередь пуста) я был отключен с этой ошибкой: DEBUG:pika.adapters.blocking_connection:Outbound buffer size: 0 DEBUG:pik

python queue rabbitmq amqp pika 2013-07-23

---

0зной

1ответ

Дизайн кода: отправьте сообщение Кролику из пробы, кроме блока

Я ищу любую помощь. Я хочу исправить функцию insert_order_queue(), чтобы отправить сообщение RabbitMQ, если сообщение на самом деле не было доставлено на сервер. Это мой текущий код: def insert_order_

python queue rabbitmq amqp pika 2013-07-25

---