From 9dfd718c3639f668596cb076e4a75acfd831a9fb Mon Sep 17 00:00:00 2001 From: crusader Date: Fri, 11 May 2018 14:24:13 +0900 Subject: [PATCH] ing --- service/CollectorService.go | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/service/CollectorService.go b/service/CollectorService.go index bbc574f..ef6d2f4 100644 --- a/service/CollectorService.go +++ b/service/CollectorService.go @@ -12,6 +12,8 @@ import ( logging "git.loafle.net/commons/logging-go" cuts "git.loafle.net/commons/util-go/time/scheduler" cutss "git.loafle.net/commons/util-go/time/scheduler/storage" + occu "git.loafle.net/overflow/commons-go/core/util" + ocmd "git.loafle.net/overflow/commons-go/model/data" ocmsc "git.loafle.net/overflow/commons-go/model/sensorconfig" ocsp "git.loafle.net/overflow/commons-go/service/probe" @@ -116,7 +118,13 @@ func (s *CollectorService) collectTask(sensorConfig *ocmsc.SensorConfig) { return } - if err := s.ProbeService.Send("DataService.Metric", sensorConfig.ConfigID, result); nil != err { + m := &ocmd.Metric{ + SensorConfigID: sensorConfig.ConfigID, + Data: result, + CollectDate: occu.NowPtr(), + } + + if err := s.ProbeService.Send("MetricService.Send", m); nil != err { logging.Logger().Errorf("Cannot send data from config id[%s] of crawler[%s] %v", sensorConfig.ConfigID, sensorConfig.Crawler.Name, err) } }