Gumbo Apache Sturm Metrics Überwachung

Question

Ich versuche Gumbo zu konfigurieren für Sturm Topologie Überwachung von here

Es ist nicht klar Beispiel ist oder Nutzung auf der Website angegeben, benötigen eine Klarstellung auf, was sind die Parameter und wo diesen Code hinzufügen oben

MonitorClient mclient = MonitorClient.forConfig(conf); 

// There are multiple metric groups, each with multiple metrics. 
// Components have names and multiple instances, each of which has an integer ID 

mclient.declare(metricGroup,metric,task_id,component_id); 

mclient.increment(metricGroup,metric, 1L , task_id); 

TaskHook.registerTo(config); 

nun auf der Website angegeben, welche Werte wir für MetricGroup, metrisch, task_id und component_id zur Verfügung stellen müssen? Wenn es notwendig ist, es von jedem Ausfluss und Bolzen zu finden, wie können wir es tun? Wo sollte dieser Code platziert werden, ist es in Topologie-Generator vor dem Einreichen der Topologie oder in einzelnen Spout/Bolt-Klasse unter Open/Prepare-Methoden oder woanders. Schätzen Sie jede Hilfe zu dieser Frage.

Answer 1

Ich probierte einige Option und unten ist die Konfiguration, die für mich arbeitete, der Gruppenname kann alles sein, Metrikname ist der Name des Streams von einer Komponente zur anderen gehen, Taskid kann jede eindeutige Tasknummer sein,

conf.put("gumbo.server.kind", "local"); 
conf.put("gumbo.local.port", 8086); //Any port it must be same in the html file 
conf.put("gumbo.start", System.currentTimeMillis()); // should be the same for all calls 
conf.put("gumbo.bucketSize", 1000L); 
conf.put("gumbo.enabled", true); 
conf.put("gumbo.http.host", "hostname"); 
conf.put("gumbo.http.port", 8086);//Any port it must be same in the html file 
conf.put("gumbo.http.app", "gumbo"); 
conf.put("gumbo.enabled", true); 
conf.put("gumbo.server.key", topology_id); 

MonitorClient mclient = MonitorClient.connect(conf); 

GumboTaskHook.registerTo(conf); 
    mclient.declare("Backlog",RTConstants.MATCH_LEFT_STREAM,3,RTConstants.TRANSFORM_LEFT_BOLT);  
    mclient.increment("Backlog",RTConstants.MATCH_LEFT_STREAM, 1L , 3); 

    mclient.declare("Backlog",RTConstants.MATCH_RIGHT_STREAM,4,RTConstants.TRANSFORM_RIGHT_BOLT);  
    mclient.increment("Backlog",RTConstants.MATCH_RIGHT_STREAM, 1L , 4);