traceId版本问题导致的serice过多，临时方案

pkg/global/global.go

@@ -103,7 +103,7 @@ func init() {
 	KafkaRecver = kafka.NewRecver(KafkaVersion, strings.Split(kafkaAddress, ","), kafkaLogger)
 
 	InfluxDbAddress = Config.GetOrDefault(NamespaceApplication, "influxdb.address", "")
-	InfluxDbAddress = "http://172.20.6.33:8086"
+	//InfluxDbAddress = "http://172.20.6.33:8086"
 	DaoFileCacheDir = Config.GetOrDefault(NamespaceApplication, "dao.file.cache.dir", "/var")
 
 	//初始化registry

pkg/points/trace_msg.go

@@ -39,6 +39,17 @@ type tags struct {
 	MvcControllerMethod string `json:"mvc.controller.method"`
 }
 
+var (
+	methodMap = map[string]struct{}{
+		"options": {},
+		"get":     {},
+		"post":    {},
+		"put":     {},
+		"delete":  {},
+		"patch":   {},
+	}
+)
+
 func TraceBaseInfoToPoint(data []byte) ([]*client.Point, error) {
 	rtn := make([]*client.Point, 0)
 	traceMsgList := make([]TraceMsg, 0)
@@ -65,6 +76,11 @@ func buildTraceInfluxMsg(traceInfo TraceMsg) *client.Point {
 		return nil
 	}
 
+	//临时：屏蔽所有options请求
+	if strings.ToLower(traceInfo.Tags.HttpMethod) == "options" {
+		return nil
+	}
+
 	bytes, err := json.Marshal(traceInfo)
 	if err != nil {
 		glog.Error("can not marshal traceInfo", traceInfo)
@@ -78,7 +94,11 @@ func buildTraceInfluxMsg(traceInfo TraceMsg) *client.Point {
 
 	tags := make(map[string]string)
 	tags["sys_name"] = traceInfo.LocalEndpoint.ServiceName
-	tags["path"] = strings.ToLower(traceInfo.Tags.HttpMethod + " " + traceInfo.Name)
+	if _, ok := methodMap[strings.ToLower(traceInfo.Tags.HttpMethod)]; ok {
+		tags["path"] = strings.ToLower(traceInfo.Tags.HttpMethod + " " + traceInfo.Tags.HttpPath)
+	} else {
+		tags["path"] = strings.ToLower(traceInfo.Name)
+	}
 	tags["host"] = traceInfo.LocalEndpoint.Ipv4
 
 	unix := time.Unix(0, traceInfo.Timestamp*1000) //精度为微秒，*1000后为纳秒