如何将apachestorm的延迟度量发送到graphite服务器？

iklwldmw 于 2021-06-24 发布在 Storm

关注(0)|答案(1)|浏览(427)

我已经配置了apachestorm，使用版本2向graphite服务器发送度量。它正在发送一个 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

apache-storm Graphite

来源：https://stackoverflow.com/questions/55335917/how-to-send-latency-metrics-from-apache-storm-to-a-graphite-server

1条答案

按热度按时间

v440hwme1#

我包括了一个 Meter 在所有螺栓上，现在它显示在graphite web服务器上。

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();
        ...
    }
}

赞(0）回复(0）举报 2021-06-24

我来回答

如何将apachestorm的延迟度量发送到graphite服务器？

1条答案

相关问题

热门标签

最新问答