Вопросы по теме 'pika'
Pika: предупреждение о превышении буфера записи
Наше программное обеспечение работало нормально в течение 5 месяцев, и теперь внезапно мы начали получать предупреждения Pika, которые в конечном итоге привели к исключению.
Pika 0.9.5 UserWarning: буфер записи превысил порог предупреждения.
Я...
1308 просмотров
schedule
08.03.2023
Создание сообщения amqp с использованием python и использование того же сообщения с использованием java
Я пытаюсь создать сообщение amqp из python и использовать это же сообщение из java/spring.
Вот мой код producer (python):
import pika, sys, pickle
sys.path.append("trc/suivi/amqp")
from Person import Person
connection =...
1605 просмотров
schedule
01.06.2022
Опрос сообщений RabbitMQ с использованием клиента Pika
Я хочу создать приемник/потребитель RabbitMQ в Python и не знаю, как проверять сообщения. Я пытаюсь сделать это в своем собственном цикле, не используя обратные вызовы в pika.
Если я что-то понимаю, в клиенте Java я могу использовать getBasic() ,...
2991 просмотров
schedule
12.06.2022
RabbitMQ в конфигурации сервера Ubuntu 14.04
У меня была эта проблема как на Amazon EC2, так и на другом VPS от другой компании, что я не мог получить доступ к серверу rabbitmq извне, чтобы использовать порт 5672 для подключения к серверу. в обоих случаях команда:
telnet <ip> 5672...
1234 просмотров
schedule
03.08.2023
Python Kombu — блокировка
Я использую kombu для управления RabbitMQ через модель производителя/потребителя. Я запустил своего производителя, который поставил в очередь 100 заданий (у меня только одна очередь и один обмен). Я хотел бы запустить несколько потребителей...
2637 просмотров
schedule
03.04.2023
Не удается подключиться к RabbitMQ на Heroku с помощью pika из-за ошибки ProbableAccessDeniedError.
Я только что установил надстройку RabbitMQ в героку. После разработки моего приложения для постановки в очередь и использования сообщений, работающих в локальном экземпляре, я развернул его на Heroku и пока не смог успешно подключиться. Имя...
4550 просмотров
schedule
06.10.2022
Метод close () для адаптера Pika SelectConnection не закрывает соединение
У меня есть простой асинхронный потребитель для AMQP / RabbitMQ, написанный на Python с использованием библиотеки Pika и основанный на Пример асинхронного потребителя из документации Pika. Основное различие заключается в том, что я хочу запустить...
2138 просмотров
schedule
02.06.2022
RabbitMQ - использует несколько очередей
Я работаю с Python, RabbitMQ и Pika.
У меня несколько потребителей и очередей. Я хочу, чтобы один потребитель получал сообщения из каждой очереди. Допустим, у меня есть 2 потребителя и 3 очереди. Я хочу, чтобы каждый из моих потребителей читал...
3633 просмотров
schedule
10.04.2022
Использовать сообщение от RabbitMQ в виде списка, используя pika в Python
У меня есть список, как показано ниже в очереди RabbitMq
[{'id':'10','url':'https://www.google.co.in/search?q=rabbitmq&oq=rabbitmq'},{'id':'11','url':'https://www.google.co.in/search?q=python&oq=python'}]
при использовании этого...
674 просмотров
schedule
23.12.2022
Что такое «извращенный» способ потребления сообщений от rabbitmq и их пересылки через клиентские соединения?
Я пишу сервер веб-сокетов в twisted , чтобы изучить структуру. Он будет получать сообщения от rabbitmq брокера и отправлять обновления подключенным клиентам. Если я хочу транслировать/рассылать много сообщений одновременно через множество...
1348 просмотров
schedule
25.07.2023
Rabbitmq одна очередь несколько потребителей
У меня несколько потребителей, которые опрашивают одну и ту же очередь и проверяют очередь каждые X секунд, в основном через X секунд может случиться так, что по крайней мере два потребителя могут запускать basic.get одновременно.
Вопрос: 1....
1271 просмотров
schedule
04.04.2023
Ошибка подключения при отправке сообщения на сервер RabbitMQ на EC2
У меня есть сервер RabbitMQ, работающий на AWS EC2. Я запустил код производителя и потребителя локально. Это работает. Я также могу получить доступ к веб-приложению управления rabbitMQ.
Когда я пытаюсь передать данные со своего ноутбука в EC2, я...
636 просмотров
schedule
17.05.2022
Пика: Как влияет параметр сердцебиения в связи?
Я искал его в официальных документах и исходном коде, но это не имеет смысла.
Я также пытаюсь установить для него значение, например 10 или 1, но он все еще показывает сердцебиение = 60 в веб-консоли управления rabbitmq.
3256 просмотров
schedule
13.07.2022
rabbitmq pika python при прерывании, завершить текущий выбранный процесс, а затем прекратить потребление новых запросов
Я запускаю несколько экземпляров потребителя rabbitmq (одна и та же очередь) через один процесс (многопроцессорность). При прерывании я хочу, чтобы все потребители корректно завершили работу. Под этим я подразумеваю, что если процесс, извлеченный из...
309 просмотров
schedule
18.12.2022
Случайные ошибки соединения с aio_pika после 2-х дней работы
У меня есть скрипт asyncio, который подключается к rabbitmq с библиотекой aio_pika каждые 40 секунд, проверяет, есть ли какие-либо сообщения, и распечатывает их, что затем повторяется вечно. Однако, как правило, примерно через 2 дня работы я начинаю...
677 просмотров
schedule
23.07.2022
Отображать виджет PyQt5 из фонового процесса
Я хочу написать программу python, работающую в фоновом режиме, и при необходимости отображать графический интерфейс PyQt5 из фонового процесса.
Мое решение — использовать RabbitMQ для работы с IPC. запуск программы с запуском PyQt в основном...
529 просмотров
schedule
07.04.2023
Как добавить тайм-аут к методу start_using() в библиотеке pika
У меня есть BlockingConnection , и я следую примерам документации pika. Но во всех них примерами кода для начала потребления сообщений являются:
connection = pika.BlockingConnection()
channel = connection.channel()...
2660 просмотров
schedule
25.07.2023
Подтверждение сообщений с помощью pika для RabbitMQ
Я использую RabbitMQ для обмена сообщениями между разными контейнерами докеров. На стороне клиента я использую pika для связи с RabbitMQ. Теперь возникла следующая проблема:
Используя BlockingConnection, я получаю сообщение от своего потребителя,...
989 просмотров
schedule
16.04.2023
Сердцебиение Пика разрывает соединение
У меня есть код, который просто ставит сообщение в очередь брокера с помощью pika.
class Publisher:
def __init__(self, config):
self._params = ConnectionParameters(
host = config.RABBITMQ_HOST,
credentials =...
97 просмотров
schedule
26.02.2024
Чтение сжатой полезной нагрузки сообщения rabbitmq с помощью pika
в отчаянии после двух дней гугления. Я получаю сообщение с pika, пришедшее от rabbitmq. Я знаю, что это base64, а content_encoding — gzip. У меня получилось закодировать тело байтов в utf-8. Теперь мне все равно нужно его как-то распаковать. Вот...
82 просмотров
schedule
30.07.2022
