Мониторинг EVTA#

Настройка#

Мониторинг производится самостоятельно через преднастроенный JMX-порт. Настройки JMX-порта задаются перед установкой в конфигурационном файле vars.yml.

Мониторинг может производиться с помощью произвольной системы мониторинга. В качестве системы мониторинга может быть использован компонент EDMN продукта Platform V Synapse Event-domain management или любая другая система мониторинга. Настройки системы мониторинга задаются в конфигурационном файле vars.yml.

Для сбора метрик в файле конфигурации adapter.conf в блоке metrics необходимо указать следующие настройки:

Параметр	Описание	Значение по умолчанию
`jmx.enabled`	Включение метрик	`true`
`jmx.domain`	Корневой пакет для метрик	`ru.sbt.ss.reactive.stream.adapter`
`jmx.step`	Интервал для агрегирующих функций	1m
`prometheus.enabled`	Включение метрик	`false`
`prometheus.histogramFlavor`	Тип формата гистограмм	Prometheus
`prometheus.step`	Интервал для агрегирующих функций	1m

Метрики#

Группа метрик «EVTA»#

Область действия метрики: EVTA

Название	Описание	Размерность	Основные атрибуты	MBEAN Name
RetryCount	Количество перезапусков EVTA	шт	count (количество)	reactive.stream.adapter:name=retry,type=meters count
FailureCount	Количество остановок EVTA вследствие ошибки	шт	count (количество)	reactive.stream.adapter:name=failure,type=meters count

Группа метрик «Producer»#

Область действия метрики: Producer

Название	Описание	Размерность	Основные атрибуты	MBEAN Name
ProducerSendMessageSuccess	Количество успешно отправленных сообщений	шт	OneMinuteRate (скорость записи за последнюю минуту)	reactive.stream.adapter:name=producerSendMessageSuccess,type=meters OneMinuteRate
ProducerSendMessageSuccess	Количество успешно отправленных сообщений	шт	count (количество)	reactive.stream.adapter:name=producerSendMessageSuccess,type=meters count
ProducerSendMessageError	Количество сообщений, отправка которых завершилась с ошибкой	шт	count (количество)	reactive.stream.adapter:name=producerSendMessageError,type=meters count
MessageProcessTime	Время обработки сообщения при отправке	мс	OneMinuteRate (скорость записи за последнюю минуту)	reactive.stream.adapter:name=messageProcessTime,type=timers OneMinuteRate
MeanMessageProcessTime	Среднее время обработки сообщения при отправке	мс	Mean (среднее время)	reactive.stream.adapter:name=messageProcessTime,type=timers Mean
PmessageAcknowledgeTime	Время получения подтверждения отправки сообщения	мс	OneMinuteRate (скорость записи за последнюю минуту)	reactive.stream.adapter:name=messageAcknowledgeTime,type=timers OneMinuteRate
MeanMessageAcknowledgeTime	Среднее время получения подтверждения отправки сообщения	мс	Mean (среднее время)	reactive.stream.adapter:name=messageAcknowledgeTime,type=timers Mean
EgressProducerSendMessageSuccess	Количество успешно отправленных сообщений через gRPC/REST	шт	OneMinuteRate (скорость записи за последнюю минуту)	reactive.stream.adapter:name=egressProducerSendMessageSuccess,type=meters OneMinuteRate
EgressProducerSendMessageError	Количество сообщений, отправка которых завершилась с ошибкой через gRPC/REST	шт	OneMinuteRate (скорость записи за последнюю минуту)	reactive.stream.adapter:name=egressProducerSendMessageError,type=meters OneMinuteRate
EgressMessageProcessTime	Время обработки сообщения при отправке через gRPC/REST	мс	OneMinuteRate (скорость записи за последнюю минуту)	reactive.stream.adapter:name=egressMessageProcessTime,type=timers OneMinuteRate
EgressMessageAcknowledgeTime	Время получения подтверждения отправки сообщения через gRPC/REST	мс	OneMinuteRate (скорость записи за последнюю минуту)	reactive.stream.adapter:name=egressMessageAcknowledgeTime,type=timers OneMinuteRate
EgressMeanMessageProcessTime	Среднее время обработки сообщения при отправке через gRPC/REST	мс	Value (изменение среднего времени)	reactive.stream.adapter:name=egressMeanMessageProcessTime,type=gauges Value
EgressMeanMessageAcknowledgeTime	Среднее время получения подтверждения отправки сообщения через gRPC/REST	мс	Value (изменение среднего времени)	reactive.stream.adapter:name=egressMeanMessageAcknowledgeTime,type=gauges Value

Группа метрик «Consumer»#

Область действия метрики: Consumer

Название	Описание	Размерность	Основные атрибуты	MBEAN Name
ConsumerReceiveMessages	Количество полученных сообщений	шт	OneMinuteRate (скорость записи за последнюю минуту)	reactive.stream.adapter:name=consumerReceiveMessages,type=timers OneMinuteRate
ConsumerReceiveMessages	Количество полученных сообщений	шт	count (количество)	reactive.stream.adapter:name=consumerReceiveMessages,type=timers Count
ConsumerErrorsCount	Количество ошибок при приеме сообщений	шт	count (количество)	reactive.stream.adapter:name=consumerErrors,type=meters count
ConsumerProcessBatch	Время обработки пачки принятых сообщений	мс	OneMinuteRate (скорость записи за последнюю минуту)	reactive.stream.adapter:name=consumerProcessBatch,type=timers OneMinuteRate
ConsumerProcessBatch	Среднее время обработки пачки принятых сообщений	мс	Mean (среднее время)	reactive.stream.adapter:name=consumerProcessBatch,type=timers Mean
ConsumerWaitDeliver	Время между приемом сообщений и началом их отправки	мс	OneMinuteRate (скорость записи за последнюю минуту)	reactive.stream.adapter:name=consumerWaitDeliver,type=timers OneMinuteRate
ConsumerWaitDeliver	Среднее время между приемом сообщений и началом их отправки	мс	Mean (среднее время)	reactive.stream.adapter:name=consumerWaitDeliver,type=timers Mean
ConsumerBufferSize	Размер используемого буфера при вычитке из EVTD /SMBX /IBM MQ	шт	Value (изменение среднего времени)	reactive.stream.adapter:name=consumerBufferSize,type=gauges Value
EgressConsumerReceiveMessagesOneMinuteRate	Количество полученных сообщений, прошедших через gRPC/REST	шт	OneMinuteRate (скорость записи за последнюю минуту)	reactive.stream.adapter:name=egressConsumerReceiveMessages,type=meters OneMinuteRate
EgressConsumerErrorsOneMinuteRate	Количество ошибок при приеме сообщений через gRPC/REST	шт	OneMinuteRate (скорость записи за последнюю минуту)	reactive.stream.adapter:name=egressConsumerErrors,type=meters OneMinuteRate
EgressConsumerProcessBatch	Время обработки пачки принятых сообщений через gRPC/REST	мс	OneMinuteRate (скорость записи за последнюю минуту)	reactive.stream.adapter:name=egressConsumerProcessBatch,type=timers OneMinuteRate
EgressConsumerProcessBatch	Среднее время обработки пачки принятых сообщений через gRPC/REST	мс	Mean (среднее время)	reactive.stream.adapter:name=egressConsumerProcessBatch,type=timers Mean
EgressConsumerWaitDeliver	Время между приемом сообщений и началом их отправки через gRPC/REST	мс	OneMinuteRate (скорость записи за последнюю минуту)	reactive.stream.adapter:name=egressConsumerWaitDeliver,type=timers OneMinuteRate
EgressConsumerWaitDeliver	Среднее время между приемом сообщений и началом их отправки через gRPC/REST	мс	Mean (среднее время)	reactive.stream.adapter:name=egressConsumerWaitDeliver,type=timers Mean

Триггеры для данных метрик настраиваются администраторами системы мониторинга самостоятельно, исходя из существующих потребностей и ограничений.