Описание тега pika
Python-Pika - это реализация протокола AMQP 0-9-1 на чистом Python, который пытается оставаться независимым от базовой сетевой библиотеки поддержки. Python-Pika был разработан в первую очередь для использования с RabbitMQ, но также должен работать с другими брокерами AMQP 0-9-1.
1
ответ
Как заставить очередь Rabbit MQ работать в режиме хранения и пересылки?
Я экспериментирую с Rabbit MQ, используя клиент Python Pika. Я хотел бы, чтобы мой отправитель AMQP работал в режиме хранения и пересылки, т. Е. Иметь возможность начинать очередь сообщений, если сервер или сеть не работает, и надежно доставлять их …
17 авг '14 в 02:21
1
ответ
Когда rabbitmq использует противодавление tcp?
Согласно документации Pika "брокер RabbitMQ использует TCP Backpressure для замедления вашего клиента, если он слишком быстро доставляет сообщения". Я зарегистрировал обратный вызов, и он еще не вызван. В моей очереди более 40 миллионов сообщений, и…
01 дек '11 в 01:57
1
ответ
Задержанные сообщения не появляются в очереди при использовании rabbitmq_delayed_message_exchange
Я пытался использовать этот плагин, и он показался мне довольно простым и эффективным. Мне удалось создать обмен, но когда я публикую запрос, если есть ненулевое значение x-delay, я не могу видеть, что сообщение передается в очередь (работает нормал…
08 фев '17 в 13:51
1
ответ
Как метод handle_delivery реализован в pika Python?
Я пытаюсь понять этот пример кода из введения в pika ( http://pika.readthedocs.io/en/0.10.0/intro.html): import pika # Create a global channel variable to hold our channel object in channel = None # Step #2 def on_connected(connection): """Called wh…
24 ноя '16 в 15:48
1
ответ
Pika - Rabbitmq, использующий Basic.get для расчета одного сообщения из очереди
Я использую метод, показанный здесь, вот так: while method_frame is None: method_frame, header_frame, method_frame= channel.basic.get("test_queue) Похоже, что этот опрос не так эффективен, потому что базовый метод get работает также, если очередь пу…
26 сен '15 в 16:39
1
ответ
Публикация и подписка через сервер rabbitmq
Мне нужен сценарий, когда один узел отправляет сообщение, а другой начинает ждать получения сообщения. Каждый узел после получения отправленного сообщения превращается в слушателя, а после получения сообщения снова превращается в издателя.
16 янв '14 в 10:36
3
ответа
Опрос сообщений RabbitMQ с использованием клиента Pika
Я хочу создать получателя / потребителя RabbitMQ на Python и не знаю, как проверять сообщения. Я пытаюсь сделать это в своем собственном цикле, не используя обратные вызовы в Пика. Если я понимаю, в клиенте Java я могу использовать getBasic() провер…
28 фев '13 в 15:11
1
ответ
Управление автоматическим удалением очередей RabbitMQ в разных потоках. питон
Я хотел бы знать, является ли это правильным способом управления очередями auto_delete в разных потоках (в основном для тестирования, когда я не хочу, чтобы очереди RabbitMQ оставались при закрытии соединения) import pika from threading import Threa…
18 май '18 в 09:52
1
ответ
Как отправить сообщения RabbitMQ актеру Pykka?
ОБНОВЛЕНИЕ Авг, 2015: Для людей, желающих использовать обмен сообщениями, в настоящее время я бы порекомендовал zeromq. Может использоваться в дополнение или в качестве полной замены pykka. Как я могу прослушать очередь RabbitMQ для сообщений и зате…
08 фев '15 в 17:52
2
ответа
При использовании Pika BlockingConnection, нужно ли basic_ack() поместить в функцию обратного вызова
Скажем, я установил соединение с RabbitMQ следующим образом: connection = pika.BlockingConnection(pika.ConnectionParameters( 'localhost', 5672, '/', credentials)) channel = connection.channel() channel.queue_declare(queue=getting_from_this_queue) ch…
08 май '17 в 05:16
1
ответ
Ведущий б в Python Пика ответ
Я пытаюсь сделать простой клиент AMQP, используя Python. Я скопировал код, который нашел на сайте RabbitMQ: #!/usr/bin/env python import pika connection = pika.BlockingConnection(pika.ConnectionParameters( host='localhost')) channel = connection.cha…
21 мар '16 в 03:31
0
ответов
Может ли клиентская служба Pika RabbitMQ потреблять и публиковать сообщения?
Может ли кто-то с опытом Пика дать мне быстрый ответ "да / нет" относительно того, возможна ли следующая функциональность, или моё мышление, что это так, указывает на отсутствие концептуального понимания Пики. Мой желаемый функционал: Служба Python …
22 окт '17 в 07:34
1
ответ
Сбой RabbitMQ Consumer при получении сообщения MQTT
Я пытаюсь опубликовать сообщение MQTT и получить сообщение с потребителем AMQP с помощью плагина RabbitMQ-MQTT в Ubuntu14.04. Я публикую сообщение MQTT с пакетом Mosquitto-clients. Я включил плагин MQTT для RabbitMQ. Теперь, если я хочу отправить со…
14 апр '15 в 09:21
2
ответа
rabbitmq / logstash потерял сообщение
У меня есть rabbitmq, который успешно хранит сообщения, но мой журнал, читающий очередь, игнорирует большинство моих сообщений. RabbitMQ в порядке , у меня есть небольшой скрипт на Python для отображения всех сообщений import pika i=0 def on_message…
25 фев '16 в 09:17
1
ответ
Pika basic_publish зависает при публикации в нескольких очередях
Мне нужно настроить несколько очередей на обмен. Я хотел бы создать одно соединение, затем объявить несколько очередей (это работает), а затем опубликовать сообщения в нескольких очередях (это не работает). Для этого я настроил некоторый тестовый ко…
15 июн '12 в 05:52
2
ответа
Как изящно приостановить и возобновить потребление в rabbitmq, pika python
Я использую basic_consume() для получения сообщений и basic_cancel для отмены потребления, но есть проблема. Вот код pika.channel def basic_consume(self, consumer_callback, queue='', no_ack=False, exclusive=False, consumer_tag=None): """Sends the AM…
18 дек '13 в 06:30
1
ответ
Pika + RabbitMQ: установка basic_qos в prefetch=1 по-прежнему, по-видимому, использует все сообщения в очереди
У меня есть рабочий клиент Python, который раскручивает 10 рабочих, каждый из которых подключается к очереди RabbitMQ. Немного так: #!/usr/bin/python worker_count=10 def mqworker(queue, configurer): connection = pika.BlockingConnection(pika.Connecti…
14 сен '12 в 14:51
1
ответ
Пика падает без видимой причины
У меня проблема. Мой клиент pika постоянно вылетает с сообщением об ошибке. Вот что происходит: RabbitMQ запущен, и производитель уже поместил сообщения в очередь Я запускаю свой скрипт на python, и он обрабатывает все пакеты, которые буферизируются…
04 дек '14 в 12:39
4
ответа
Сбой соединения RabbitMq с 127.0.0.1:5672
В настоящее время я следую учебнику rabbitmq и сталкиваюсь с проблемой. Независимо от того, насколько близко я следую руководству, я получаю эту ошибку, пытаясь запустить мои send.py и receive.py: pika.exceptions.ConnectionClosed: Connection to 127.…
20 мар '18 в 21:10
1
ответ
Правильный конфиг, используя rabbitmq в качестве сельдерея
Я создаю приложение фляги с сельдереем, используя rabbitmq в качестве основы сельдерея. мой конф для сельдерея CELERY_BROKER_URL='amqp://localhost:5672', CELERY_RESULT_BACKEND='amqp://', CELERY_QUEUE_HA_POLICY='all', CELERY_TASK_RESULT_EXPIRES=None …
23 дек '14 в 16:08