Вопросы по теме 'pika'
Как Python может определить, что мой пароль RabbitMQ не удалось?
Я пытаюсь написать приложение Python, использующее RabbitMQ, с помощью библиотеки Pika . Я использую последнюю версию 0.9.5. Моя проблема в том, что мой код Python не может определить, когда его имя пользователя и пароль RabbitMQ неверны, потому...
1749 просмотров
schedule
09.02.2024
Автоматическое переподключение Rabbitmq pika
У меня есть несколько скриптов, использующих pika.SelectConnection для связи с сервером RabbitMq.
Можно ли как-то заставить эти скрипты автоматически переподключаться к серверу rmq в случае, если сервер вышел из строя, пока скрипт работает?
1616 просмотров
schedule
08.02.2023
RabbitMQ/Pika — гарантия получения сообщений в том порядке, в котором они были созданы?
В качестве простого примера я добавляю 5 элементов в новую очередь RabbitMQ (v 2.6.1):
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host='not.my.real.server.net'))
channel = connection.channel()...
3029 просмотров
schedule
12.05.2023
Какую форму соединения использовать с пикой
Я пытался выяснить, какую форму соединения я должен использовать при использовании pika, насколько я понимаю, у меня есть две альтернативы.
Либо BlockingConnection , либо SelectConnection , однако я не совсем уверен в различиях между этими двумя...
9407 просмотров
schedule
10.12.2022
Хороший интервал сердцебиения для pika-rabbitmq в Amazon ec2
Я использую последнюю версию библиотеки pika (0.9.9+) для rabbitmq. Я использую rabbitmq и pika следующим образом:
У меня как рабочих есть длительные задачи (около 5 минут). Эти задачи берут свои запросы от rabbitmq. Запросы поступают очень...
3072 просмотров
schedule
06.05.2023
Можно ли перемещать/объединять сообщения между очередями RabbitMQ?
Я хочу узнать, можно ли перемещать/объединять сообщения из одной очереди в другую. Например:
main-queue содержит сообщения ['cat-1','cat-2','cat-3','cat-4','dog-1','dog-2','cat-5']
dog-queue содержит сообщения ['dog-1, dog-2, dog-3, dog-4]...
13682 просмотров
schedule
30.08.2023
Twisted и Pika - Как добавить обратный вызов к вызову подтверждения сообщения?
Я использую адаптер протокола twisted от pika. Когда я успешно обработал сообщение, я отправляю подтверждение RabbitMQ, используя этот вызов:
channel.basic_ack(delivery_tag=delivery_tag)
Вызов basic_ack, похоже, запускается асинхронно, но...
833 просмотров
schedule
25.04.2024
Как подключить pika к удаленному серверу rabbitMQ? (питон, пищуха)
На моей локальной машине я могу иметь:
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
для обоих сценариев (send.py и recv.py), чтобы установить надлежащую связь, но как насчет установления связи с 12.23.45.67 по...
25135 просмотров
schedule
27.03.2024
Ошибка потребителя RabbitMQ при получении сообщения MQTT
Я пытаюсь опубликовать сообщение MQTT и получить сообщение от потребителя AMQP с помощью плагина RabbitMQ-MQTT в Ubuntu14.04. Я публикую сообщение MQTT с пакетом Mosquitto-clients. Я включил плагин MQTT для RabbitMQ.
Теперь, если я хочу отправить...
706 просмотров
schedule
09.06.2024
RabbitMQ: потребление только одного сообщения за раз из нескольких очередей
Я пытаюсь оставаться на связи с несколькими очередями в RabbitMQ. Каждый раз, когда я выталкиваю новое сообщение из одной из этих очередей, я хотел бы создать внешний процесс.
Этот процесс займет некоторое время, чтобы обработать сообщение, и я не...
1218 просмотров
schedule
12.05.2022
Pika не может использовать RabbitMQ с удаленного IP-адреса
Я использую Python и pika, потому что хочу отправлять данные с RabbitMQ с сервера на другой.
Я следовал следующему руководству по созданию потребителя и производителя: https://www.rabbitmq.com/tutorials/tutorial-one-python.html
На той же...
455 просмотров
schedule
02.07.2023
Как удалить сообщение в rabbitmq с помощью pika?
Как удалить опубликованное и полученное сообщение в очереди rabbitmq. Я тестирую rabbitmq с python, используя pika .
Как я могу удалить сообщение, которое опубликовано и получено?
2164 просмотров
schedule
04.08.2022
Pika python ждет RabbitMQ Publisher, если очередь достигает предела
У меня есть сценарий, скрипт python, который будет публиковать, скажем, 150 КБ сообщений с максимальным размером каждого сообщения 10 КБ. Затем я установлю ограничение очереди на максимум 5000 сообщений. Затем издатель будет публиковать сообщение в...
721 просмотров
schedule
24.11.2023
Как правильно выполнить одиночную блокировку, синхронный прием с Pika?
Я хотел бы использовать Pika/RabbitMQ по образцу, аналогичному стандартному сокету: то есть настроить соединение, затем сделать блокирующие синхронные вызовы для получения одного сообщения каждый раз, когда я готов выполнить дополнительную работу....
220 просмотров
schedule
18.11.2022
Как интегрировать Pika с Qt?
Недавно пользователь спросил, как использовать Pika с Qt, но неожиданно пользователь удалил, когда я собирался опубликовать свой ответ, что дало мне возможность предложить этот вопрос с автоответом, где я пытаюсь представить различные решения:
401 просмотров
schedule
08.01.2024
Как безопасно потреблять из эксклюзивной очереди в RabbitMQ?
В конфигурации удаленной клиентской процедуры (RPC) клиентские очереди объявляются эксклюзивными, как показано в официальное руководство . Если клиент получает сообщение из своей эксклюзивной очереди и происходит сбой до его подтверждения, я ожидаю,...
51 просмотров
schedule
24.03.2024
