Работа с метриками#

Метрики шагов трансформации и агрегации событий#

Для шагов, описанных в разделах Трансформация событий и Агрегация событий, используются следующие метрики:

  1. input — количество входящих событий:

    • для трансформации: 0.transformation-transformationStepName.input;

    • для агрегации: 0.aggregation-transformationStepName.input.

  2. output — количество исходящих событий, которые передаются в основной поток обработки:

    • для трансформации: 0.transformation-transformationStepName.output;

    • для агрегации: 0.aggregation-transformationStepName.output.

  3. reject — количество событий, которые были отфильтрованы и не прошли через обработку:

    • для трансформации: 0.transformation-transformationStepName.reject;

    • для агрегации: 0.aggregation-transformationStepName.reject.

  4. error — количество событий, обработанных с ошибкой:

    • для трансформации: 0.transformation-transformationStepName.error;

    • для агрегации: 0.aggregation-transformationStepName.error.

  5. branch-branchStep — количество событий, переданных в дополнительную ветку обработки с первым шагом "branchStep":

    • пример: 0.route-transformationStepName.branch-branchStep.

  6. name — пользовательская метрика, определенная через DSL:

    • для трансформации: 0.transformation-transformationStepName.name;

    • для агрегации: 0.aggregation-transformationStepName.name.

Управление метриками через DSL#

Увеличение метрики (incrementMetric)#

Функция «incrementMetric» увеличивает метрику из первого параметра на величину из второго параметра.

Синтаксис#

incrementMetric("имя_метрики", [число])

Аргументы:#

  1. Строка — имя метрики.

  2. Число, на которое необходимо увеличить метрику. По умолчанию: если число не указано, метрика увеличивается на 1.

Примеры использования#

incrementMetric("metricName")
incrementMetric("metricName", 3)

Уменьшение метрики (decrementMetric)#

Функция «decrementMetric» уменьшает метрику из первого параметра на величину из второго параметра.

Синтаксис#

decrementMetric("имя_метрики", [число])

Аргументы:#

  1. Строка — имя метрики.

  2. Число, на которое необходимо уменьшить метрику. По умолчанию: если число не указано, метрика уменьшается на 1.

Примеры использования#

decrementMetric("metricName")
decrementMetric("metricName", 3)