Tagged: rabbitmq

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

Каждая таск…

31
Янв
2018

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

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

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

30
Авг
2017

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

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

30
Авг
2017

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

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

04
Июл
2016

Вопрос по поводу очередей в RabbitMQ

Здравствуйте. Я пытаюсь написать очередь на rabbitmq.
На всех туториалах которых я смотрел, все работает следующим образом:

Есть код (отправитель), который посылает сообщение в очередь Rabbit’a и сразу завершается.
Есть код (получатель),…