Откуда могут быть просадки в rabbitmq?

Question

[xcuube]

Всем привет и с наступающим!

Имею очередь в rabbitmq, данные из которой забирает кликхаус, с этим проблем нет, но есть какие-то странные просадки по поступлению сообщений в очередь, которые происходят каждые 2 минуты стабильно. В чем может быть проблема? Сообщения точно летят без таких пауз, как отображаются на графике

Comments

[Everything_is_not_so_bad]

Надо смотреть код издателя, судя по графику.

[xcuube]

Роман Мирр, вот код, эндпоинт в симфони, в него приходят данные и оттуда уже идут в очередь rabbitmq

$connection = new AMQPStreamConnection(
            $_ENV['RABBIT_IP'],
            $_ENV['RABBIT_PORT'],
            $_ENV['RABBIT_USER'],
            $_ENV['RABBIT_PASSWORD'],
            '/',
            false,
            'AMQPLAIN',
            null,
            'en_US',
            30, //Connection Timeout
            30, // Read/Write Timeout
            null,
            false,
            60
);
$channel = $connection->channel();

$channel->queue_declare('RequestLog', false, false, false, false);

$msg = new AMQPMessage($request->getContent());
$channel->basic_publish($msg, 'clickhouse-exchange', 'RequestLog');

$channel->close();
$connection->close();

[Everything_is_not_so_bad]

Тогда нужно во всей цепочке вести мониторинг темпа получения и отправки данных.

[Everything_is_not_so_bad]

Кстати, быстро открывать/закрывать соединение не рекомендуется для RabbitMQ.

[xcuube]

Роман Мирр, как тогда в моем случае лучше поступить, чтобы не открывать/закрывать часто?

[Everything_is_not_so_bad]

xcuube,

как тогда в моем случае лучше поступить, чтобы не открывать/закрывать часто?

Просто держать соединение открытым. Если оно обрывается, переподключаться.

Answer 1

[ComodoHacker]

Возможно, сброс данных на диск? Наложите на график дисковой активности.

Не уверен, что это проблема. Если система работает в рамках ожиданий, все OK.

Comments

[xcuube]

Теряются некоторые сообщения.

[Everything_is_not_so_bad]

xcuube, при помощи ведения учета количества отправленных/принятых можно понять какое звено сбоит.