Описание тега py-amqplib
3
ответа
Получение количества сообщений в очереди RabbitMQ
Мы используем amqplib для публикации / использования сообщений. Я хочу иметь возможность прочитать количество сообщений в очереди (в идеале как подтвержденные, так и неподтвержденные). Это позволит мне показать симпатичную диаграмму состояния пользо…
22 май '13 в 11:58
1
ответ
py-amqp/flopsy: ожидание одного сообщения AMQP в Python
У меня есть вопрос, похожий на этот: в py-amqp / flopsy очень легко сказать: "Я буду ждать вечно, и я хочу, чтобы этот обратный вызов вызывался всякий раз, когда приходит сообщение", но я не могу найти любой способ сказать: "Хорошо, я получил сообще…
28 июн '10 в 19:46
5
ответов
Ожидание одного сообщения RabbitMQ с таймаутом
Я хотел бы отправить сообщение на сервер RabbitMQ, а затем дождаться ответного сообщения (в очереди для ответа). Конечно, я не хочу ждать вечно, если приложение, обрабатывающее эти сообщения, не работает - должен быть тайм-аут. Это звучит как очень …
10 май '10 в 00:26
2
ответа
Как удалить привязку очереди из RabbitMQ?
Я использую RabbitMQ для маршрутизации сообщений заинтересованным подписчикам по темам. У каждого подписчика есть очередь, и я связываю очередь с интересующими его темами. Я бы хотел, чтобы пользователь мог удалить элемент из списка тем. В моей наст…
23 ноя '10 в 15:46
3
ответа
Как использовать listen на basic.return в python-клиенте AMQP
Я хочу убедиться, что мое сообщение было доставлено в очередь. Для этого я добавляю обязательный параметр в basic_publish. Что еще я должен сделать, чтобы получить basic.return сообщение, если мое сообщение не было успешно доставлено? Я не могу испо…
03 фев '10 в 12:08
0
ответов
Ошибка закрытия соединения py-amqplib только в Google App Engine
Я пытаюсь использовать py-amqplib в Google App Engine для связи с кластером rabbitmq (также хостом на App Engine). У меня все работает, как и ожидалось, за исключением того, что, когда я иду, чтобы закрыть соединение, я выдал исключение Exception on…
04 мар '15 в 00:20
1
ответ
Qpid ( AMQP) для TCL?
Кто-нибудь знает какие-либо привязки или примеры использования tcl с qpid? В настоящее время я использую библиотеки QPID в Python. Но чтобы изменить существующие приложения TCL, я ищу библиотеки QPID в TCL. Заранее благодарю за любую помощь
06 мар '15 в 05:10
0
ответов
Не могу установить максимальную длину очереди в Rabbitmq
Я пытаюсь установить максимальную длину для очереди Rabbitmq, используя библиотеку Python amqplib. Но очередь не становится ограниченной. http://www.rabbitmq.com/maxlength.html Я каждый раз сбрасывал сервер Rabbitmq, чтобы удалить очередь. Что я дел…
30 июл '13 в 14:09
1
ответ
Node.js+node_amqp.js не может подключиться к ActiveMQ с портами 61616 или 5672
Нужен совет. Это пример, который я запускаю на node.js: var amqp = require('amqplib'); amqp.connect('amqp://localhost:61616').then(function(conn) { conn.once('SIGINT', function() { conn.close(); }); return conn.createChannel().then(function(ch) { va…
19 авг '13 в 14:07
1
ответ
Как ждать сообщения в нескольких очередях, используя py-amqplib
Я использую py-amqplib для доступа к RabbitMQ в Python. Приложение время от времени получает запросы на прослушивание определенных тем MQ. При первом получении такого запроса он создает соединение AMQP и канал и запускает новый поток для прослушиван…
27 ноя '09 в 06:34
1
ответ
AMQP транзакции с Kombu и Rabbitmq
Кажется, я не могу найти какую-либо документацию по использованию транзакций AMQP через API Kombu. На этой странице говорится о добавлении сообщения в состояние транзакции, но оно не похоже на связанное. Я знаю, что бэкэнд pika поддерживает их, и я …
29 июн '11 в 13:56
1
ответ
Librabbitmq 2.0.0 с Python 3 дает TypeError: не может выбирать объекты памяти
Я использую последнюю главную ветку git-репозитория https://github.com/celery/librabbitmq и устанавливаю librabbitmq==2.0.0 для Python 3.6, следуя инструкциям в readme Использование разрабатываемой версии Вы можете клонировать репозиторий, выполнив …
01 май '18 в 00:03
2
ответа
Несколько потребителей и производителей подключены к очереди сообщений. Возможно ли это в AMQP?
Я хотел бы создать ферму процессов, способных распознавать текст. Я думал об использовании одной очереди сообщений, которая читается несколькими процессами OCR. Я хотел бы убедиться, что: каждое сообщение в очереди в конечном итоге обрабатывается ра…
29 янв '10 в 10:16
1
ответ
Несколько рабочих используют одно и то же сообщение из очереди RabbitMQ
Я использую модуль py-amqp и Python 3.4. Когда я запускаю более 1 слушателя и запускаю одного производителя для публикации сообщений, слушатели берут одно сообщение и начинают обрабатывать его одновременно. Мне не нужно такое поведение, потому что с…
21 апр '14 в 13:10
1
ответ
Публикация сообщений в двух очередях RabbitMQ вместо одной (с использованием py-amqp)
У меня странная проблема с использованием py-amqp и модуля Flopsy. Я написал издателя, который отправляет сообщения на сервер RabbitMQ, и я хотел иметь возможность отправить его в указанную очередь. В модуле Flopsy это невозможно, поэтому я настроил…
27 апр '10 в 08:10
2
ответа
Как обнаружить обмен не существует с py-amqp
Я хочу иметь возможность определить, существует ли обмен при отправке сообщения в AMQP. Рассмотрим следующий пример. #!/usr/bin/python import amqp from time import sleep conn = amqp.Connection(host="localhost:5672", userid="guest", password="guest",…
19 фев '13 в 22:10
0
ответов
Поддерживает ли py-amqp AMQP 0-10?
Мой клиент использует qpid-cpp-broker для обмена сообщениями AMQP. Наше приложение построено на Python 3, поэтому я не смог использовать API обмена сообщениями Python Qpid (он поддерживает только Python 2.7). Я пытаюсь использовать py-amqp для отпра…
01 авг '18 в 22:07