Как отправить метрики задержки из Apache Storm на сервер Graphite?

Question

Я настроил Apache Storm для отправки метрик на сервер Graphite с использованием версии 2 . Он посылает count параметр всех моих болтов и носиков. Я хотел бы передать задержку между связью болтов и патрубков, а также время для обработки каждого кортежа на них. Тем не менее, все, что я нахожу на сервере Graphite, это метрики, связанные с count кортежами на болтах и ​​патрубках. Документация говорит, что можно собирать гистограммы, таймеры и т. Д., Но не объясняет, как это можно собрать.

# Metrics v2 configuration (optional)
storm.metrics.reporters:
  # Graphite Reporter
  - class: "org.apache.storm.metrics2.reporters.GraphiteStormReporter"
    daemons:
        - "supervisor"
        - "nimbus"
        - "worker"
    report.period: 30
    report.period.units: "SECONDS"
    graphite.host: "127.0.0.1"
    graphite.port: 2003

Answer 1

Я включил Meter во все болты, и теперь он отображается на веб-сервере Graphite.

public class MqttSensorDetailSpout extends BaseRichSpout {
    ...
    private Meter tupleMeter;
    public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
        this.tupleMeter = context.registerMeter("meterSpout-" + this.topic);
    }
    public void nextTuple() {
        this.tupleMeter.mark();
        ...
    }
}