Вопросы по теме 'pika'
Установить время ожидания для асинхронного режима Pika ioloop (RabbitMQ)
Мне нужно иметь возможность изящно остановить потребителя (работника), который работает в iloop Pika. Рабочий должен остановиться через 60 секунд. Обрабатываемые в настоящее время сообщения должны быть завершены.
Я попытался поместить...
7298 просмотров
schedule
27.06.2022
Как узнать, было ли сообщение опубликовано в очереди, используя функции маршрутизации rabbitmq
Я работал над проектом, в котором для общения используется rabbitmq. Недавно мы обнаружили, что было бы намного масштабируемо, если бы мы использовали функцию маршрутизации кролика. Таким образом, мы привязываем очередь к нескольким ключам...
3369 просмотров
schedule
14.10.2023
Сбой приложения после слишком большого количества пропущенных сердцебиений
У меня есть приложение, которое распределяет нагрузку на группу рабочих. Пока что все рабочие процессы работают на одной и той же виртуальной машине, масштабирование пока не требуется. Моя проблема в том, что, как и каждые 3-4 дня, рабочий вылетает...
3303 просмотров
schedule
11.02.2023
Python Pika — потребитель в потоке
Я работаю над приложением Python с фоновым потоком для использования сообщений из очереди RabbitMQ (тематический сценарий).
Я запускаю поток в событии on_click кнопки. Вот мой код, обратите внимание на "#self.receive_command()".
def...
9421 просмотров
schedule
24.06.2022
Как общаться RabbitMQ (библиотека Pika) в приложении торнадо
Библиотека Pika поддерживает адаптер торнадо, здесь приведен пример публикации сообщения с помощью асинхронного адаптера. .
Я хочу использовать pika в приложении торнадо, просто пример, я хочу поместить данные запроса торнадо в RabbitMQ, но не...
6611 просмотров
schedule
18.12.2022
AMQP: подтверждение и предварительная выборка
Я пытаюсь разобраться в некоторых аспектах протокола AMQP. В настоящее время у меня есть проект с RabbitMQ и использую библиотеку python pika. Итак, вопрос касается подтверждения и предварительной выборки сообщений.
Предположим, у нас есть...
8801 просмотров
schedule
21.09.2023
Правильный способ отменить потребление rabbitmq с помощью pika
Я хочу реализовать клиент rpc с помощью rabbitmq. Мой код в первую очередь выглядит как
def start(self):
while True:
self.channel.basic_consume(self.on_delivery)
...
client.start() // blocking call
Как правильно остановить...
1424 просмотров
schedule
01.10.2022
Соединение закрыто в rabbitmq по какой-то причине через некоторое время
Я использую библиотеку pika python для подключения к серверу rabbitmq на локальном хосте.
class BaseRabbitSender(MessageSender):
__metaclass__ = ABCMeta
def __init__(self, host):
self.node = BaseMessagingNode(host)...
8003 просмотров
schedule
03.01.2023
Отклонение и повторная постановка задачи RabbitMQ в очередь, когда prefetch_count == 1
Предположим, у меня есть очередь с пятью элементами:
(tail) E, D, C, B, A (head)
Я потребляю сообщения из головы этой очереди, но решаю, что сообщение A не подходит для обработки в настоящее время. Я reject этот элемент с requeue=True ,...
3656 просмотров
schedule
24.04.2022
Использовать несколько очередей в python / pika
Я пытаюсь создать потребителя, который будет подписываться на несколько очередей, а затем обрабатывать сообщения по мере их поступления.
Проблема в том, что когда в первой очереди уже присутствуют некоторые данные, они потребляют первую очередь и...
12955 просмотров
schedule
11.05.2023
RabbitMQ изменяет параметры очереди в производственной системе
Я использую RabbitMQ в качестве очереди сообщений в сервис-ориентированной архитектуре, где многие отдельные веб-службы публикуют сообщения, привязанные к очередям RabbitMQ. На эти очереди, в свою очередь, подписываются различные потребители, которые...
14370 просмотров
schedule
02.09.2022
Как заставить очередь Rabbit MQ работать в режиме хранения и пересылки?
Я экспериментирую с Rabbit MQ, используя клиент Python Pika. Я хотел бы, чтобы мой отправитель AMQP работал в режиме сохранения и пересылки, т. е. имел возможность начинать ставить сообщения в очередь, если сервер или сеть не работают, и надежно...
920 просмотров
schedule
10.10.2022
Как сделать простой Pika SelectConnection для отправки сообщения в python?
Я пытаюсь преобразовать свой код для отправки сообщений rabbitmq через Pika. У меня много проблем с пониманием того, как отправить простое сообщение с использованием асинхронного соединения (например, SelectConnection).
В моем старом коде, в...
3650 просмотров
schedule
01.11.2022
как асинхронно потреблять из 2 очередей RabbitMQ от одного потребителя с помощью pika
Я пишу потребителя, которому нужно использовать из двух разных очередей.
1-> для фактических сообщений (заранее объявленная очередь).
2-> для командных сообщений для управления поведением потребителя (динамически объявляется потребителем и...
4738 просмотров
schedule
25.02.2022
прервать поток с помощью метода start_consuming pika
У меня есть ветка, которая прослушивает новые сообщения от rabbitmq с помощью pika. После настройки соединения с помощью BlockingConnection я начинаю получать сообщения через start_consuming. Как я могу прервать вызов метода запуска, чтобы,...
2448 просмотров
schedule
18.05.2023
Блокирующее соединение Rabbitmq для получения сообщений от RabbitMQ и использование блокирующего соединения для получения сообщения от RabbitMQ
Я довольно запутался между двумя методами работы с библиотекой rabbitmq's pika .
Первый — Блокировка потребления Второй — Блокировка basic_get Может ли кто-нибудь более подробно объяснить различия?
Есть ли разница в том, что блокировка...
244 просмотров
schedule
01.08.2022
Удаленный вызов Rabbitmq с Pika
Я новичок в rabbitmq и пытаюсь понять, как я могу заставить клиент запрашивать сервер с информацией об использовании памяти и ЦП с помощью этого руководства ( https://www.rabbitmq.com/tutorials/tutorial-six).-python.html ).
Итак, клиент запрашивает...
2361 просмотров
schedule
09.08.2022
Невозможно получить доступ к серверу RabbitMQ от других клиентов в сети из-за ошибки аутентификации
Я установил RabbitMQ на Ubuntu 14.04 и не могу подключиться к серверу RabbitMQ с других компьютеров в сети.
Проблем с подключением к серверу с машины, на которой установлен RabbitMQ, нет, только с других компьютеров в сети.
На На этой странице...
5824 просмотров
schedule
29.10.2022
комбу не подключается к RabbitMQ
У меня есть два сервера, назовем их A и B. B запускает RabbitMQ, а A подключается к RabbitMQ через Kombu. Если я перезапущу RabbitMQ на B, соединение kombu разорвется, и сообщения больше не будут доставляться. Затем мне нужно сбросить процесс на A,...
941 просмотров
schedule
29.06.2022
установить «x-message-ttl» в pika python
Я хочу установить TTL на 1 секунду для очереди Rabbitmq, используя pika. Я попробовал следующий код
import ctypes
int32=ctypes.c_int
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel =...
3710 просмотров
schedule
12.08.2022
