# 添加部分数据

service/agent_msg_process.go

@@ -5,20 +5,27 @@ import (
 	"fmt"
 	"git.quantgroup.cn/DevOps/enoch/service/end_points"
 	"github.com/influxdata/influxdb/client/v2"
+	"math/big"
+	"net"
 	"time"
 )
 
+var sysNameIndex = make(map[int64]bool)
+
 func AgentMsgProcess(msg string) {
-	chunkMsg := enn_points.ChunkMsg{}
+	chunkMsg := end_points.ChunkMsg{}
 	err := json.Unmarshal([]byte(msg), &chunkMsg)
 	if err != nil {
 		fmt.Println(err)
 	}
-
 	buildMetricsInfluxMsg(chunkMsg)
 }
 
-func buildMetricsInfluxMsg(chunkMsg enn_points.ChunkMsg) {
+func buildMetricsInfluxMsg(chunkMsg end_points.ChunkMsg) {
+	var ip = inetAtoN(chunkMsg.Ip)
+	println("ip:%d", ip)
+	sysNameIndex[ip] = true
+	var sysNameCount = len(sysNameIndex)
 	for _, p := range chunkMsg.EndPoints {
 		tags := make(map[string]string, )
 		tags["sys_name"] = chunkMsg.AppName
@@ -62,15 +69,24 @@ func buildMetricsInfluxMsg(chunkMsg enn_points.ChunkMsg) {
 		fields["gc_concurrent_mark_sweep"] = metrics.GcConcurrentmarksweepCount
 		fields["gc_concurrent_mark_time"] = metrics.GcConcurrentmarksweepTime
 
-		fields["processors"] = metrics.Processors
+		fields["uptime"] = metrics.Uptime
+		fields["instance_uptime"] = metrics.InstanceUptime
+		fields["system_load_average"] = metrics.SystemloadAverage
 
-		unix := time.Unix(0, p.Timestamp)
-		if (len(pointSlice) == batchSize) {
+		unix := time.Unix(0, p.Timestamp*1000000)
+		println(p.Timestamp)
+		if len(pointSlice) >= sysNameCount {
 			go batchWrite(pointSlice)
 			pointSlice = make([]*client.Point, 0, batchSize)
 		}
+		println(len(pointSlice))
 		point, _ := client.NewPoint("machine_info", tags, fields, unix)
 		pointSlice = append(pointSlice, point)
 	}
+}
 
+func inetAtoN(ip string) int64 {
+	ret := big.NewInt(0)
+	ret.SetBytes(net.ParseIP(ip).To4())
+	return ret.Int64()
 }