Публикации по теме 'amqp'
Как заменить опрос базы данных на RabbitMQ
База данных традиционно используется для хранения данных, но я видел, как разработчики использовали таблицы базы данных в качестве очереди заданий. Цель очереди заданий - отслеживать, какие данные необходимо обработать после того, как они были вставлены в эту таблицу. Затем выделенный процесс должен периодически опрашивать / запрашивать необработанные данные в таблице базы данных. В зависимости от частоты опроса и наличия необработанных данных этот метод может стать очень неэффективным...
Вопросы по теме 'amqp'
Как использовать внешний сервер с Ruby AMQP Carrot Library
Я использую библиотеку Ruby AMQP Carrot и пытаюсь поговорить с тестовым сервером RabbitMQ на виртуальной машине. Порт AMQP открыт на машине, но я не могу заставить Carrot установить внешнее соединение. Я пробовал следующее:...
1186 просмотров
schedule
17.04.2022
Какой режим доставки в AMQP?
Я так понимаю, что возможны 2 варианта:
«Нестойкий»
"Настойчивый"
Но что это на самом деле означает?
«Непостоянный», как в: структура AMQP попытается доставить сообщение, если нет потребителей, сообщение будет удалено?
«Постоянный»,...
55410 просмотров
schedule
17.07.2023
Размещение сообщений в двух очередях RabbitMQ вместо одной (с использованием py-amqp)
У меня возникла странная проблема с использованием py-amqp и модуль Flopsy . Я написал издатель, который отправляет сообщения на сервер RabbitMQ, и я хотел иметь возможность отправлять его в указанную очередь. В модуле Flopsy это невозможно,...
449 просмотров
schedule
16.05.2022
Подписчик AMQP внутри приложения Rails
Можно ли начать подписку AMQP с моим приложением Rails? Возможно, через инициализатор или что-то в этом роде.
Я хотел бы, чтобы он работал одновременно с моделями Rails. Ниже приведен пример псевдокода того, что я имею в виду.
queue.subscribe...
3380 просмотров
schedule
11.10.2022
Как сделать отказоустойчивость очередей RabbitMQ?
RabbitMQ по умолчанию поддерживает кластеризацию, но очереди не реплицируются и привязываются к узлу, на котором они созданы. Теперь я ищу способы сделать RabbitMQ высокодоступным, кроме решения DRBD, которое они задокументировали, потому что кажется...
14531 просмотров
schedule
01.01.2023
Как выборочно удалять сообщения из очереди AMQP (RabbitMQ)?
Я хотел бы выборочно удалять сообщения из очереди AMQP, даже не читая их.
Сценарий следующий:
Отправляющая сторона хочет истечь сроком действия сообщений типа X на основании того факта, что поступила новая информация типа X. Поскольку очень...
34502 просмотров
schedule
15.02.2023
работающий клиент останавливается через несколько секунд после запуска
Привет, я пытаюсь использовать RabbitMQ вместо Starling. Я настроил свое приложение, и все вроде бы хорошо, но когда я запускаю «script/workling_client start», оно начинает работать и заканчивается через несколько секунд, и я не могу понять, почему...
137 просмотров
schedule
25.04.2022
Как отозвать сообщение в RabbitMQ?
У меня есть что-то вроде очереди заданий над RabbitMQ, и при запросе на отмену задания я хотел бы отозвать задачи, которые еще не начали обрабатывать (их сообщения не были подтверждены), что соответствует отзыву эти сообщения из очередей, в которые...
10423 просмотров
schedule
23.05.2022
Кому-нибудь удалось использовать сельдерей с пилонами
У меня есть веб-приложение на основе пилонов, и я хотел бы использовать сельдерей + rabbitmq в течение некоторого времени, выполняя задачи. Я посмотрел на проект пилонов сельдерея, но мне не удалось его использовать.
Моя основная проблема с...
663 просмотров
schedule
11.05.2022
XMPP/AMQP/Websockets против Pusher/Beacon push?
С помощью облачных сервисов Pusher и Beacon я могу получать оперативные обновления во всех браузерах. Даже реализовать функциональность чата.
Разве эти облачные сервисы не могут заменить мне необходимость изучения XMPP/AMQP/Websockets/Comet для...
3336 просмотров
schedule
13.04.2023
Python/Джанго AMQP?
У меня есть веб-приложение Django, которое создает и сохраняет задания в базе данных. Для каждой работы мне приходится отправлять электронную почту и экспортировать данные в другую систему. Я хочу сделать асинхронный.
Каков рекомендуемый способ...
2388 просмотров
schedule
31.01.2023
Дизайн системы обмена сообщениями
Я ищу способ отправлять запросы и получать ответные звонки от другой стороны.
Единственная проблема в том, что мы не знаем, как это будет спроектировано/развернуто на стороне получателя.
У нас есть текстовые/JSON-сообщения, определенные и...
330 просмотров
schedule
03.06.2023
Как запустить демон qpidd, прослушивая 127.0.0.1, а не 0.0.0.0
Я не нашел никакой полезной информации на qpid.apache.org, как начать прослушивание демона qpidd по адресу, отличному от 0.0.0.0. Есть идеи?
257 просмотров
schedule
12.04.2022
Будет ли puka хорошо работать с gevent или eventlet?
Я читал о более новой библиотеке Python AMQP Puka (не путать с Pika), и мне было интересно, будет ли способ обработки цикла событий совместим с gevent или eventlet. Основываясь на моих ограниченных знаниях, кажется, что вы можете автоматически...
1300 просмотров
schedule
27.04.2024
Как использовать amq.topic для публикации/подписки сообщений в Apache Qpid
У меня есть издатель С++ для отправки таких сообщений:
Connection connection;
connection.open("127.0.0.1", 5672);
Session session = connection.createSession();
Message msg;
msg.setData("TestAMsg");...
2195 просмотров
schedule
26.08.2022
Можно ли использовать обмен в RabbitMQ?
Может быть, я задаю здесь неправильный вопрос.
что я пытаюсь сделать: несколько производителей передают данные в динамических категориях в именованный обмен. несколько потребителей должны получать эти данные из этих очередей с динамическими...
3557 просмотров
schedule
15.10.2022
Существует ли JMS API/клиент, который работает со всеми брокерами AMQP?
JMS — это независимый от поставщика API для обмена сообщениями в пространстве Java. Миссия AMQP состоит в том, чтобы «стать стандартным протоколом для взаимодействия между всем промежуточным ПО для обмена сообщениями». Я ищу реализацию клиента JMS,...
3810 просмотров
schedule
11.05.2022
кодировка сообщений python qpid
Я пытаюсь получать сообщения от брокера amqp в python. Вот мой код:
#!/usr/bin/python
import sys
import os
import getopt
from qpid.messaging import *
from qpid.log import enable, DEBUG
broker_rcv = "admin/admin@hostname:IP"
address_rcv =...
773 просмотров
schedule
30.11.2023
RabbitMQ Как настроить производителя и клиентскую среду?
У меня есть новая установка RabbitMQ на сервере linux/ubuntu. Допустим, сервер работает под доменом superserver.com. Какие шаги я должен предпринять сразу после его установки, потому что я не могу подключиться к нему с удаленного...
2266 просмотров
schedule
19.12.2022
Выборочная маршрутизация с RabbitMQ
У меня есть очереди, привязанные к одной теме обмена, например с ключами маршрутизации:
1) big.yellow.rabbit
2) small.*.dog
3) small.*.*
4) *.*.cat
5) *.*.*
Я хочу, чтобы RabbitMQ выбрал только одну очередь для размещения моего сообщения...
1788 просмотров
schedule
24.04.2023
