Описание тега python-pika
Python-Pika - это реализация протокола AMQP 0-9-1 на чистом Python, который пытается оставаться независимым от базовой сетевой библиотеки поддержки. Python-Pika был разработан в первую очередь для использования с RabbitMQ, но также должен работать с другими брокерами AMQP 0-9-1.
1
ответ
Публикация и подписка через сервер rabbitmq
Мне нужен сценарий, когда один узел отправляет сообщение, а другой начинает ждать получения сообщения. Каждый узел после получения отправленного сообщения превращается в слушателя, а после получения сообщения снова превращается в издателя.
16 янв '14 в 10:36
1
ответ
Выберите строки с n по n, в то время как в таблице все еще есть значения, невыбранные с помощью python и pyodbc
У меня есть таблица с 10000 строк, и я хочу выбрать первые 1000 строк, а затем снова выбрать и на этот раз следующий набор строк, который составляет 1001-2001. Я использую BETWEEN предложение для выбора диапазона значений. Я также могу увеличивать з…
07 май '15 в 01:23
0
ответов
Может ли клиентская служба Pika RabbitMQ потреблять и публиковать сообщения?
Может ли кто-то с опытом Пика дать мне быстрый ответ "да / нет" относительно того, возможна ли следующая функциональность, или моё мышление, что это так, указывает на отсутствие концептуального понимания Пики. Мой желаемый функционал: Служба Python …
22 окт '17 в 07:34
1
ответ
Как rabbitmq синхронизирует сообщения?
Я использую этот простой код, используя pika: conn = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) channel = conn.channel() def on_message(ch, method, properties, message): print("Received message: %r" % message) channel.basic…
31 янв '19 в 17:25
2
ответа
Попытка получить кролик MSG без подтверждения, но безуспешно
У меня есть задача, в которой я пытаюсь получить все сообщения в очереди кролика. Мне нужно только ПОЛУЧИТЬ, а не ПОТРЕБИТЬ. Так вот код, я использую def some_function_name() : connection = rabbitObj.get_connection() channel = rabbitObj.get_channel(…
12 сен '17 в 08:12
0
ответов
Подписка на нескольких производителей в RabbitMQ
У меня есть одно сомнение. прежде всего, дайте мне знать, я думаю, правильно или нет. здесь идет моя постановка проблемы. У меня есть два продюсера. производитель_1 и производитель_2 и один потребитель производитель_1, производитель_2 выполнят некот…
24 сен '18 в 19:26
1
ответ
Почему циклический вызов требуется при использовании из очереди?
Я пытаюсь потреблять из кроличьих очередей, используя пика и витая: Постоянно (новое сообщение -> потреблять) Один раз (новое сообщение -> потреблять один раз, не потреблять снова, пока я не скажу) Единственный вход у меня есть, это пример. Он охват…
11 апр '18 в 01:56
1
ответ
Заставить работников мгновенно получать сообщения о сбоях, когда включен режим постоянной доставки
У меня установлен сервер RabbitMQ, где я получаю сообщения, используя Python-Pika. Проблема в том, что если у меня включен постоянный режим доставки, и рабочие не могут обработать сообщение. Вместо выпуска сообщения оно будет сохраняться до тех пор,…
15 апр '13 в 11:03
3
ответа
Как проверить, нет ли сообщения в RabbitMQ с Pika и Python
Я читаю сообщения от RabbitMQ с библиотекой pika python. Чтение сообщений в цикле выполняется connection = rpc.connect() channel = connection.channel() channel.basic_consume(rpc.consumeCallback, queue=FromQueue, no_ack=Ack) channel.start_consuming()…
05 окт '18 в 09:14
1
ответ
Публикация / подписка MQTT-сообщения через RabbitMQ с использованием pika (клиент Python)
У меня есть существующий сервер RabittMQ, и мы включили плагин MQTT для публикации / подписки сообщений mqtt. У нас есть клиент pika для обработки существующих сообщений очереди. Сейчас мы хотим использовать тот же обработчик pika on_message() для о…
08 ноя '17 в 12:59
1
ответ
Python 3.6: Как создать потребителя pika с помощью адаптера SelectConnection без использования класса?
Я новичок в Python и Pika, и я сталкиваюсь с проблемами, потребляющими из очереди, используя адаптер BlockingConnection, который продолжает выдавать исключение через несколько часов. Поэтому я сейчас пытаюсь использовать адаптер SelectConnection (As…
23 авг '17 в 03:03
2
ответа
Невозможно получить доступ к серверу RabbitMQ с других клиентов в сети из-за ошибки аутентификации
Я установил RabbitMQ в Ubuntu 14.04 и не могу подключиться к серверу RabbitMQ с других компьютеров в сети. Нет проблем с подключением к серверу с компьютера, на котором установлен RabbitMQ, только с других компьютеров в сети. На этой странице указан…
15 мар '16 в 11:46
1
ответ
Что делает "d.addCallback(лямбда-протокол: protocol.ready)" в примере Twisted Pika?
Настройка в примере кода Pika с Twisted выглядит следующим образом: parameters = pika.ConnectionParameters() cc = protocol.ClientCreator( reactor, twisted_connection.TwistedProtocolConnection, parameters) d = cc.connectTCP('hostname', 5672) d.addCal…
12 окт '15 в 07:19
0
ответов
Как создать новый канал из одного соединения (pika/rabbitmq)?
Я пишу код на Python, используя pika 0.9.13 для подключения к RabbitMQ. Я создаю много дочерних процессов (потенциально 1000) и хочу, чтобы каждый процесс мог отправлять их в RabbitMQ. Читая вокруг, кажется, что лучший способ - создать одно соединен…
19 июл '13 в 14:53
1
ответ
Неожиданное pika.exceptions.ConnectionClosed исключение
Я случайно получаю следующие ошибки (т.е. в большинстве случаев скрипты работают нормально) File ".../backend/case_status_consumer.py", line 28, in <module> channel.start_consuming() File "/usr/local/lib/python2.7/dist-packages/pika/adapters/b…
23 июл '15 в 01:01
0
ответов
Сигнал SIGHUP дает исключение с pika в Python 2.7
У меня есть потребитель Пика, когда я запускаю его и посылаю сигнал SIGHUP, это дает мне исключение Consumertest.py import signal import traceback import pika from time import sleep received_signal = False def signal_handler(signal, frame): global r…
09 окт '14 в 15:33
1
ответ
Как переиздать сообщения с pika и RabbitMQ
Мне нужно прослушать сообщения RabbitMQ, немного обработать каждое сообщение и отправить его на другой обмен. Каждый пример, который я видел до сих пор, включает в себя либо это: reader_connection.ioloop.start() или это: writer_connection.ioloop.sta…
14 мар '16 в 17:37
1
ответ
Пика - Как обработать исключение NoneTypes, когда начать потреблять
Я пытаюсь проверить channel.consume при получении сообщения от сервера RabbitMQ с помощью Pika 0.11.2 Когда звоните get_mq и я обнаружил, что: исключение произошло, когда пустое сообщение в очереди. Итак, как я могу подтвердить исключение Вот мой ко…
11 апр '18 в 16:47
1
ответ
Python - передать переменную функции (обратного вызова) между функциями, выполняющимися в отдельных потоках
Я пытаюсь разработать скрипт Python 3.6, который использует модули pika и threading. У меня есть проблема, которая, как мне кажется, вызвана тем, что я А) очень плохо знаком с Python и программированием в целом, и Б) не понимаю, как передавать перем…
31 июл '17 в 15:41
6
ответов
python нет имени модуля pika при импорте pika
Я установил Пика для Python, работающего на Mac sudo pip install pika==0.9.8 Я уверен, что установлен, это ответ при попытке переустановить, Requirement already satisfied (use --upgrade to upgrade): pika==0.9.8 in /usr/local/lib/python2.7/site-packa…
30 окт '13 в 04:09