Flink со сравнением показателей счетчика StatsD - PullRequest
Новая
       31

Flink со сравнением показателей счетчика StatsD

0 голосов
/ 23 января 2020

Говоря о счетчиках в отношении StatsD, он работает так, что вы продолжаете публиковать значения счетчика, например. numOfRequests|c:1 всякий раз, когда приложение получает запрос к демону StatsD. У демона установлен интервал гриппа sh, когда он передает совокупность этого счетчика за этот период во внешний бэкэнд. Кроме того, он также сбрасывает счетчик на 0.

Попытка отобразить это на счетчики Flink.

  1. Счетчики мерцания имеют только методы c и de c, поэтому до наступления отчетного времени приложение может вызвать c или de c, чтобы изменить значение счетчика.
  2. Во время создания отчета последнее значение счетчика передается демону StatsD, но значение счетчика Flink никогда не сбрасывается (невозможно найти код).

Таким образом, если счетчик мерцания должен сообщаться в StatsD как калибровочное значение. Или Flink сбрасывает счетчики?

1 Ответ

0 голосов
/ 23 января 2020

Счетчики мерцания в основном являются своего рода калибровочными значениями. Счетчики никогда не сбрасываются. Так что numRecordsIn/numRecordsOut или любые другие контр-метрики продолжали увеличиваться в течение всего срока работы. Если вы хотите визуализировать счет по длительности, вам нужно рассчитать и отправить дельту во внешний бэкэнд самостоятельно в методе отчета или использовать возможности внешнего бэкэнда для построения графика дельты.

Мы используем Datadog и использовали следующие для отображения дельты за период: diff(sum:numRecordsIn{$app_name,$env}.rollup(max))

...