Gumbo Apache tempête Surveillance Metrics

Question

Je suis en train de configurer Gumbo pour la surveillance de la topologie de tempête de here

Il n'y a pas exemple clair ou l'utilisation donnée sur le site, ont besoin des éclaircissements sur ce que sont le paramètre et où ajouter ce code donnée sur le site ci-dessus

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); 

maintenant, quelles sont les valeurs que nous devons prévoir MetricGroup, métrique, task_id et ID_composant? Si besoin de le trouver de chaque bec et boulon comment pouvons-nous le faire? Où ce code devrait-il être placé, est-ce dans le générateur de topologie avant de soumettre la topologie ou dans une classe individuelle de bec/boulon sous des méthodes ouvertes/préparées ou ailleurs. Appréciez toute aide sur cette question.

Answer 1

J'ai essayé quelques options et ci-dessous est la configuration qui a fonctionné pour moi, le nom de groupe peut être quelque chose, nom métrique est le nom du flux sortant d'un composant à l'autre, taskid peut être un numéro de tâche unique,

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);