Публикации по теме 'rabbitmq'


Повышение скорости отклика API: использование RabbitMQ для внедрения асинхронной обработки в Node.js
В современных веб-приложениях довольно часто встречаются сценарии, в которых выполнение определенных задач может занять значительное время. Эти задачи часто называют «длительными заданиями» , и они могут варьироваться от сложных вычислений, обработки изображений или данных до ресурсоемких операций, таких как создание отчетов. Эти задачи потенциально могут повлиять на скорость отклика приложения. Таким образом, чтобы обеспечить удобство работы пользователей и быстроту отклика нашего..

Запуск серверов RabbitMQ с тестовыми контейнерами в Node.js
Вводный пример JavaScript для неинициированных Testcontainers с использованием библиотеки amqplib Тестконтейнеры — это здорово, но нет модуля RabbitMQ для Тестконтейнеров Node.js , и правильная настройка контейнера оказалась не такой интуитивной, как я ожидал… так что вот простой пример установки и установки тестовых контейнеров RabbitMQ. работает с использованием GenericContainer вместе с соответствующей стратегией ожидания: const { GenericContainer, Wait } =..

Вопросы по теме 'rabbitmq'

Stomp Broadcast с Rabbitmq и Python
Я пытаюсь перевести систему с использования morbid на rabbitmq, но, похоже, я не могу получить такое же поведение вещания morbid, которое предоставляется по умолчанию. Под широковещательной рассылкой я подразумеваю, что когда сообщение добавляется в...
4095 просмотров
schedule 21.11.2023

RabbitMQ дает отказ в доступе, отказ в входе в систему из-за ошибки пользователя при попытке следовать учебнику по сельдерею
Я пытаюсь следовать руководству по сельдерею , но столкнулся с проблемой когда я запускаю python manage.py celeryd : мой сервер RabbitMQ (установленный на виртуальной машине в моем окне разработки) не позволяет моему пользователю войти в систему....
7552 просмотров
schedule 15.04.2024

Лучшая клиентская библиотека PHP для доступа к RabbitMQ (AMQP)?
На сайте RabbitMQ есть список PHP-клиентов . Я задаю этот вопрос в надежде, что люди, которые использовали любой из них, могут поделиться здесь своим опытом. Например. Были ли у вас проблемы с установкой? Это стабильно? Были ли проблемы с...
23767 просмотров
schedule 15.12.2023

Сельдерей (Джанго) Ограничение скорости
Я использую Celery для обработки нескольких задач интеллектуального анализа данных. Одна из этих задач подключается к удаленной службе, которая допускает не более 10 одновременных подключений на пользователя (или, другими словами, МОЖЕТ превышать...
7773 просмотров
schedule 10.05.2024

Расчет среднего времени приема-передачи (AMQP / RabbitMQ)
Учитывая кластер узлов RabbitMQ с кучей очередей, получающих сообщения от обмена темами, я хотел бы иметь возможность программно ответить на вопрос: Для очереди X какова текущая приблизительная оценка времени доставки сообщения /...
720 просмотров
schedule 31.12.2023

Как написать собственный сток Flume OG
Мы используем Flume, и мне нужно собрать несколько сообщений журнала в rabbitmq. Я нашел источник, реализацию , который читает сообщения от rabbitmq, но не смог найти приемник который может писать сообщения в кролика. Так что я думал о том, чтобы...
4241 просмотров
schedule 22.09.2022

Потребитель RabbitMQ перестает получать сообщения
У меня серьезная проблема с RabbitMQ. После получения определенного количества сообщений потребители просто перестают получать сообщения. Они все еще подключены, но больше не получают сообщений. Я нашел другие сообщения об этой проблеме, но у них...
9134 просмотров
schedule 01.12.2022

Переход с ActiveMQ на RabbitMQ
В настоящее время я использую ActiveMQ для обмена сообщениями; за исключением нескольких сбоев БД, он работал хорошо. Однако я, по крайней мере, подумываю о том, чтобы попробовать RabbitMQ. Но прежде, чем я это сделаю, я хотел бы понять следующее:...
31064 просмотров
schedule 02.11.2022

celery+rabbitmq пустая очередь
Я использую celery+rabbitmq. Я не могу найти удобный способ очистить очередь в celery+rabbitmq. Я делаю это с удалением и созданием vhost. rabbitmqctl delete_vhost <vhostpath> rabbitmqctl add_vhost <vhostpath> Это...
5465 просмотров
schedule 22.10.2022

Статус Джанго-сельдерея ПОЛУЧЕН?
Я запускаю некоторые задачи через django-celery (с rabbitmq в качестве бэкэнда), задачи требуют много времени и интенсивно используют процессор. У меня есть 2 рабочих экземпляра Ec2 (один маленький, а другой - средний по процессору). Я настроил...
444 просмотров
schedule 04.01.2024

Celery, rabbitmq: как установить удаленного работника?
Могу ли я иметь несколько машин для выполнения задач и возврата сообщений, распространяемых django? Я просмотрел celery/rabbitmq, я не уверен, смогу ли я настроить сельдерейных рабочих на удаленных компьютерах. Может ли кто-нибудь провести меня...
1317 просмотров
schedule 19.12.2023

Как настроить очередь так, чтобы все подписчики получали сообщения - Rabbit MQ
Я читаю книгу RabbitMQ в действии, все еще в главе 2, но одна вещь, о которой говорят авторы, меня озадачивает. Вы настраиваете обмен и отправляете сообщение, очередь слушают два абонента. Когда приходит первое сообщение, его получает первый...
8224 просмотров
schedule 28.11.2022

Как прослушивать тысячи незанятых почтовых ящиков imap через spring/amqp/rabbit
Вариант использования состоит в том, чтобы сервер подключался к тысячам учетных записей электронной почты пользователей и обнюхивал входящую почту в java, предпочтительно с java mail и масштабируемой инфраструктурой типа Spring Integration/amqp/rabbit...
1431 просмотров

Реализация очереди сообщений
Я ищу самый быстрый способ зарегистрировать сообщение без подключения производителя к какому-либо серверу при отправке журнала. Наилучшим сценарием было бы просто быстро записать сообщение во что-то локальное (память, локальная очередь сообщений), а...
1013 просмотров
schedule 28.11.2023

Как сохранить в очереди только одно (последнее) сообщение от каждого издателя?
Интересно, как увеличить канал, очередь или сервер RMQ, чтобы хранить только одно последнее сообщение от каждого издателя? Есть ли в RMQ какой-либо способ сделать это без модификации сервера RMQ -> перекомпиляция?
2385 просмотров
schedule 11.06.2024

Плагин RabbitMQ Shovel застрял в стартовом состоянии
RabbitMQ запускается нормально, но статус плагина лопаты указан как «запуск». Я использую следующий rabbitmq.config: Каждый брокер работает на отдельном экземпляре AWS. Удаленный сервер — это сервер Windows 2008, локальный сервер — Amazon...
5563 просмотров
schedule 04.03.2024

Pika/RabbitMQ: правильное использование add_backpressure_callback
Я новичок в использовании RabbitMQ и Pika, поэтому извините, если ответ очевиден... Мы загружаем некоторые данные и передаем результаты в нашу очередь сообщений rabbitmq. Очередь используется процессом, который записывает данные в elasticsearch....
661 просмотров
schedule 22.10.2022

Очередь Rabbitmq с разветвлением процесса в PHP
У меня есть простой работник очереди, основанный на стандартном классе AMQP из PHP. Он работает с RabbitMQ в качестве сервера. У меня есть класс очереди для инициализации соединения AMQP с RabbitMQ. Все отлично работает с приведенным ниже кодом:...
1223 просмотров
schedule 30.11.2023

Драйвер RabbitMQ С# перестает получать сообщения
Есть ли у вас какие-либо указания, как определить, когда возникла проблема с подпиской, чтобы я мог повторно подключиться? Мой сервис использует RabbitMQ.Client.MessagePatterns.Subscription для своей подписки. Через некоторое время мой клиент...
15497 просмотров
schedule 01.01.2024

Недостатки блокировки строк в MySQL
Я использую блокировку строк (транзакции) в MySQL для создания очереди заданий. Используемый движок - InnoDB. SQL-запрос START TRANSACTION; SELECT * FROM mytable WHERE status IS NULL ORDER BY timestamp DESC LIMIT 1 FOR UPDATE; UPDATE...
878 просмотров
schedule 26.10.2022