Pull to refresh

Comments 5

тяжела эта русска языка

Реально сложно :)

Queue

Durable значит, что exchange сохранится после перезагрузки Rabbit.

По всей видимости, для раздела про очередь имелось ввиду "Durable значит, что queue сохранится после перезагрузки Rabbit".

Отличная статья!

Важное замечание: не следует использовать amqproxy для consumer, есть проблемы одностороннего разрушения соединений.

А вот столкнулись тут недавно с одной проблемой, связанной с проксированием, что через amqproxy, что через haproxy, через какое-то время перестают приходить ответы на rpc запросы в celery.

Если celery.broker и celery.backend указать на сам сервер rabbitMQ, то всё работает стабильно. Но через проси нет, задача создаётся в брокере, но от нескольких минут до нескольких часов проходит, и просто перестаёт приходить ответ. Причём через этого же самого брокера сообщения в очереди уходят, но механизм rpc ломается.

Было подозрение что столкнулись с "флаппингом каналов", про него тоже в статье упомянули, очень сильно увеличилось время ответа, и как раз порядок кол-ва примерно похож, но с проксированием ничего не получилось. Пока решилось переработкой логики продюсеров, но вопрос остался, что не так с проксированием ampq.

Sign up to leave a comment.