Tagged: rabbitmq

30
Июл
2021

Настройка Spring Cloud Rabbit

Сделал рабочую конфигурацию для реббита, суть которой перебрасывать из основной очереди в ожидающую (dead-letter) с заданным ttl и по его истечении забрасывать обратно:
@Configuration
@AllArgsConstructor
public class RabbitConfig {

public…

24
Июн
2021

Как в rabbitmq накопить определённое кол-во строк и запустить эту пачку в callback?

На данный момент работает так – идёт запрос с множеством данных на сервис А, с него данные посылаются в очередь в rabbitmq, откуда читаются по одному сообщению сервисом В и пишутся в CLickHouse. Нужно сделать так, чтобы в сервисе В сообщен…

24
Июн
2021

Как в rabbitmq накопить определённое кол-во строк и запустить эту пачку в callback?

На данный момент работает так – идёт запрос с множеством данных на сервис А, с него данные посылаются в очередь в rabbitmq, откуда читаются по одному сообщению сервисом В и пишутся в CLickHouse. Нужно сделать так, чтобы в сервисе В сообщен…

23
Июн
2021

RabbitMq можно ли реализовать отправку пакетами транзакционно?

Я выбираю из базы postgres пакет объектов (допустим по 5 тыс) и хочу переложить все эти объекты в очередь RabbitMq (приложение на спринге). Если объект успешно попал в очередь, то я меняю статус этого объекта в базе на "отправлен&quot…

20
Май
2021

Rabbitmq. Можно ли создать очередь, которая подвязана к Direct Exchange, но при этом в нее будут попадать все сообщения независимо от routing key?

Суть проблемы, существует сервис на спринге, который закидывает сообщения в Direct exchnage без указания routing key. Есть очередь которая подвязана к этому обменнику и у нее тоже отсутвcует routing key, и эта очередь должна получать абсол…

10
Фев
2021

Проблема с rabbitmq

Я тут попробовал поиграться с rabbitmq.
Но я столкнулся с проблемой, когда пробую подключиться к нему(rabbitmq), у меня вылазит ошибка:
pika.exceptions.IncompatibleProtocolError: StreamLostError: (‘Transport indicated EOF’,)
Может кто-то у…

10
Фев
2021

Проблема с rabbitmq

Я тут попробовал поиграться с rabbitmq.
Но я столкнулся с проблемой, когда пробую подключиться к нему(rabbitmq), у меня вылазит ошибка:
pika.exceptions.IncompatibleProtocolError: StreamLostError: (‘Transport indicated EOF’,)
Может кто-то у…

10
Фев
2021

Проблема с rabbitmq

Я тут попробовал поиграться с rabbitmq.
Но я столкнулся с проблемой, когда пробую подключиться к нему(rabbitmq), у меня вылазит ошибка:
pika.exceptions.IncompatibleProtocolError: StreamLostError: (‘Transport indicated EOF’,)
Может кто-то у…

16
Сен
2020

Nameko RPC имеет не достаточную пропускную способность, как улучшить?

Решился попробовать микросервисную архитектуру, я использую Flask + UWsgi + nginx для apigateway и Rabbitmq + Nameko + Python для связи с сервисами.
В итоге заметил такую проблему, Nameko создает в RabbitMQ свою очередь на которую подписыв…

16
Сен
2020

Nameko RPC имеет не достаточную пропускную способность, как улучшить?

Решился попробовать микросервисную архитектуру, я использую Flask + UWsgi + nginx для apigateway и Rabbitmq + Nameko + Python для связи с сервисами.
В итоге заметил такую проблему, Nameko создает в RabbitMQ свою очередь на которую подписыв…

30
Июл
2020

Я не понимаю как настроить celery и rabbitmq на Windows

Сейчас покажу код, делаю на ubuntu все то же самое, что и на Windows
Windows код не исполняет, не отправляет email, с ubuntu этот же проект работает прекрасно.Как заставить работать celery на windows?
settings.py

EMAIL_HOST = ‘smtp.gmail….

01
Июл
2020

Установить RabbitMQ для Laravel 5.8. Ошибка composer – Your requirements could not be resolved to an installable set of packages

Всем заглянувшим, доброго времени суток!
Сам сервер запускается и работает нормально(Docker).
Но при добавлении данной либы через composer composer require vladimir-yuldashev/laravel-queue-rabbitmq получаю исключения.
Your requirements …

10
Июн
2020

Вернуть ответ клиенту из после RabbitMQ

Есть сервер, который принимает запрос от клиента и отправляет в RabbitMQ, есть слушатель, который получает сообщения из очереди, обрабатывает его и должен обратно вернуть клиенту.Вопрос в том, как вернуть сообщение именно определенному кли…

30
Мар
2020

Не запускается flower python

При запуске flower выходит данная ошибка, не могу понять в чем дело, может кто нибудь сталкивался с подобным? Пишу интернет магазин на django в связке с rabbitmq и celery

(venv) PS D:\myinternetshop\myshop> celery -A myshop flower
[I…

06
Фев
2020

Как распределять запросы на микросервисы?

Допустим от клиента пришел запрос в API.
API или что то ещё при получении запроса к API, решает создать очередь в rabbit mq , для 3 – 10 микросервисы одновременно.

Так вот кто решает то? Кто, а точнее что, верховодит над созданием очереде…

03
Янв
2020

Теряются задачи

Всем привет, использую в проекте Django, Celery и RabbitMQ. Заметил, что при большой нагрузке кол-во Processed не равно кол-ву Succeeded + Failed.
Например сейчас
Processed: 1598741
Succeeded: 1598591
Failed : 1
Retried : 0

Каждая таск…

03
Янв
2020

Теряются задачи

Всем привет, использую в проекте Django, Celery и RabbitMQ. Заметил, что при большой нагрузке кол-во Processed не равно кол-ву Succeeded + Failed.
Например сейчас
Processed: 1598741
Succeeded: 1598591
Failed : 1
Retried : 0

Каждая таск…

09
Апр
2018

Универсальный JMS клиент

Я пишу приложение spring-boot, которое должно получать и отправлять JMS-сообщения. Адрес, порт, логин и пароль для подключения к брокеру читаются из конфигов. Изначально я не знаю, с каким типом брокера придется работать. Существует ли уни…

31
Янв
2018

Распределение задач RabbitMQ по алгоритму round-robin

Доброго времени суток.

В проекте реализованы очереди на RabbitMQ с алгоритмом round-robin распределения задач по воркерам. Выявлена проблема – имеется три воркера, первый получил задачу – работает, второй, третий получили – быстро отрабо…

30
Авг
2017

Дублирование сообщений при падении RabbitMQ или воркера

Имеется схема RPC в которой приложение на Java (будем называть его TaskManager’ом) отправляет задания в очередь RabbitMQ (очередь A) к приложениям на PHP (назовем их Worker’ами). После выполнения задания воркер отправляет сообщение с резул…