msg 转移到field

service/msg_process.go

@@ -46,18 +46,17 @@ func msgInfluxProcess(traceMsgs []TraceMsg) {
 		fields := make(map[string]interface{})
 		fields["duration"] = traceMsg.Duration / 1000
 		fields["traceId"] = traceMsg.TraceId
+		bytes, err := json.Marshal(traceMsg)
+
+		msg := string(bytes)
+
+		fields["msg"] = msg
+
 		tags := make(map[string]string, )
 		tags["sys_name"] = sysName
 		tags["path"] = path
 		tags["host"] = traceMsg.LocalEndpoint.Ipv4
-		tags["kind"] = traceMsg.Kind
-		tags["duration_tag"] = strconv.Itoa(traceMsg.Duration)
-
-		bytes, err := json.Marshal(traceMsg)
-
-		msg := string(bytes)
 
-		tags["msg"] = msg
 
 		if err != nil {
 			log.Fatal(err)
@@ -86,6 +85,7 @@ func batchWrite(pointArray []*client.Point) {
 
 	points, err := client.NewBatchPoints(client.BatchPointsConfig{
 		Database: "monitor",
+		//Precision : "ms",
 	})
 	if err != nil {
 		log.Fatal(err)