Как сбросить метрики каждые X секунд?

Question

Я пытаюсь измерить показатели приложения и jvm уровня в своем приложении, используя DropWizard Metrics library.

Ниже приведен мой класс показателей, который я использую через свой код для увеличения/уменьшения метрик. Я вызываю increment и decrement метод класса ниже для увеличения и уменьшения показателей.

public class TestMetrics { 
    private final MetricRegistry metricRegistry = new MetricRegistry(); 

    private static class Holder { 
    private static final TestMetrics INSTANCE = new TestMetrics(); 
    } 

    public static TestMetrics getInstance() { 
    return Holder.INSTANCE; 
    } 

    private TestMetrics() {} 

    public void increment(final Names... metricsName) { 
    for (Names metricName : metricsName) 
     metricRegistry.counter(name(TestMetrics.class, metricName.value())).inc(); 
    } 

    public void decrement(final Names... metricsName) { 
    for (Names metricName : metricsName) 
     metricRegistry.counter(name(TestMetrics.class, metricName.value())).dec(); 
    } 

    public MetricRegistry getMetricRegistry() { 
    return metricRegistry; 
    } 

    public enum Names { 
    // some more fields here 
    INVALID_ID("invalid-id"), MESSAGE_DROPPED("drop-message"); 

    private final String value; 

    private Names(String value) { 
     this.value = value; 
    } 

    public String value() { 
     return value; 
    } 
    }; 
} 

А вот как я использую выше TestMetrics класса для увеличения метрики базы на случай, когда мне нужно. Ниже метод вызывается несколькими потоками.

public void process(GenericRecord record) { 
    // ... some other code here 
    try { 
     String clientId = String.valueOf(record.get("clientId")); 
     String procId = String.valueOf(record.get("procId")); 
     if (Strings.isNullOrEmpty(clientId) && Strings.isNullOrEmpty(procId) 
      && !NumberUtils.isNumber(clientId)) { 
     TestMetrics.getInstance().increment(Names.INVALID_ID, 
      Names.MESSAGE_DROPPED); 
     return; 
     } 
     // .. other code here 

    } catch (Exception ex) {  
     TestMetrics.getInstance().increment(Names.MESSAGE_DROPPED); 
    } 
    } 

Теперь у меня есть еще один класс, который ходит каждые 30 секунд только (я использую рамки Quartz для этого), где я хочу, чтобы напечатать все показатели и его количество. В общем, я буду отправлять эти показатели каждые 30 секунд в какую-то другую систему, но сейчас я распечатываю ее здесь. Вот как я это делаю.

public class SendMetrics implements Job { 

    @Override 
    public void execute(final JobExecutionContext ctx) throws JobExecutionException { 
    MetricRegistry metricsRegistry = TestMetrics.getInstance().getMetricRegistry(); 
    Map<String, Counter> counters = metricsRegistry.getCounters(); 
    for (Entry<String, Counter> counter : counters.entrySet()) { 
     System.out.println(counter.getKey()); 
     System.out.println(counter.getValue().getCount()); 
    } 
    } 
} 

Теперь я задаю вопрос: я хочу, чтобы все мои показатели учитывались каждые 30 секунд. Значение, когда мой метод execute распечатывает метрики, он должен распечатывать показатели только за 30 секунд (только для всех показателей) вместо того, чтобы печатать на протяжении всей продолжительности с момента запуска программы.

Есть ли способ, чтобы все мои показатели имели счет только 30 секунд. Граф того, что произошло за последние 30 секунд.

Answer 1

В ответ, потому что это слишком долго:

Вы хотите сбросить счетчики. Для этого нет API. Причины обсуждаются в связанной проблеме github. В статье описывается возможное обходное решение. У вас есть ваши счетчики и используйте их как обычно - увеличивая и уменьшая. Но вы не можете их сбросить. Поэтому добавьте новый Gauge, значение которого следует за счетчиком, который вы хотите сбросить после того, как он сообщил вам. Метод getValue()Gauge вызывается, если вы хотите сообщить значение счетчика. После сохранения текущего значения метод уменьшает значение счетчика с ним. Это эффективно сбросит счетчик до 0. Таким образом, у вас есть отчет, а также сброс счетчика. Это описано в Step 1.

Step 2 добавляет фильтр, который запрещает сообщать фактический счетчик, поскольку теперь вы сообщаете через датчик.