0
ответов
Соединение Производителя RabbitMQ блокирует Потребителя в питоне с Комбу и Пикой
Я сталкиваюсь со странной проблемой, с которой я борюсь с этим пару дней. Он появляется только в «производственной» среде. Это установка: приложение Python 3, которое запускает очередь ...
вопрос задан: 11 March 2019 15:02
0
ответов
Какую форму соединения использовать с пищухой
Я пытался выяснить, какую форму соединения я должен использовать при использовании pika, насколько я понимаю, у меня есть две альтернативы. Либо BlockingConnection, либо SelectConnection, однако...
вопрос задан: 16 August 2012 13:19
0
ответов
Случайная ошибка тайм-аута с Pika и gevent
Я пытался использовать RabbitMQ из моей программы gevent, используя библиотеку Pika (обезьяна, исправленная gevent), gevent любит случайно выдавать ошибку тайм-аута. Что мне делать? Есть ли...
вопрос задан: 30 June 2012 18:02
0
ответов
Есть ли способ составить список очередей в rabbitmq через pika?
Я знаю, что мы можем сделать это, чтобы перечислить очередь в rabbitmq. rabbitmqctl list_queues, но как это сделать через pika?
вопрос задан: 11 March 2012 03:56
0
ответов
Асинхронная обработка сообщений клиентом Pika RabbitMQ
Следуя примеру Pika с синхронизацией полученных сообщений, я хотел бы, чтобы клиент обрабатывал больше одновременных запросов. Мой вопрос заключается в следующем: если handle_delivery можно было бы каким-то образом вызывать каждый раз при получении нового
вопрос задан: 6 March 2012 14:55
0
ответов
RabbitMQ, Pika и стратегия повторного подключения
Я использую Pika для обработки данных из RabbitMQ.
Поскольку я столкнулся с различными проблемами, я решил написать небольшое тестовое приложение, чтобы посмотреть, как я могу обрабатывать разъединения. Я написал это тестовое приложение...
вопрос задан: 29 February 2012 23:21
0
ответов
Ошибка «неизвестный тег доставки» возникает, когда я пытаюсь подтвердить сообщения RabbitMQ с помощью pika (python)
Я хочу обрабатывать сообщения в нескольких потоках, но при выполнении этого кода я получаю сообщение об ошибке: from __future__ import with_statement
импортная пища
import sys
from pika.adapters.blocking_connection import ...
вопрос задан: 22 February 2012 09:49
0
ответов
Когда rabbitmq использует обратное давление tcp?
Согласно документации Pika «брокер RabbitMQ использует обратное давление TCP, чтобы замедлить вашего клиента, если он доставляет сообщения слишком быстро. . " Я зарегистрировал обратный вызов обратного давления, и он еще не был ...
вопрос задан: 1 December 2011 01:57
0
ответов
Как реализовать приоритетные очереди в RabbitMQ / pika
Я ищу возможность реализовать приоритетную очередь с RabbitMQ. В списке рассылки рекомендуется использовать несколько очередей, каждая из которых представляет свой уровень приоритета. У меня вопрос, как вы опрашиваете ...
вопрос задан: 12 October 2011 15:21
0
ответов
Какой лучший шаблон для разработки асинхронного приложения RPC с использованием Python, Pika и AMQP?
Модуль производителя моего приложения запускается пользователями, которые хотят представить работу, которые будут выполнены в небольшом кластере. Он отправляет подписки в форме JSON через Broker Mankitmq Message. Я пробовал ...
вопрос задан: 13 September 2011 15:26
0
ответов
Как мне восстановить неподтвержденные сообщения AMQP из каналов, отличных от канала моего соединения?
Кажется, чем дольше я держу сервер rabbitmq в рабочем состоянии, тем больше у меня проблем с неподтвержденными сообщениями. Я бы с удовольствием запросил их. На самом деле, похоже, для этого существует команда amqp, но она ...
вопрос задан: 15 August 2011 09:01