From 0247b4944585e0d2472850ccf8dfbf2ee49de656 Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期四, 21 十一月 2019 16:46:47 +0800
Subject: [PATCH] fix taskRate
---
EsApi.go | 10 +++++-----
1 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/EsApi.go b/EsApi.go
index a5651cb..99fd9e9 100644
--- a/EsApi.go
+++ b/EsApi.go
@@ -448,9 +448,9 @@
}
},
"aggs":{
- "sdkId_status":{
+ "sdkName_status":{
"terms":{
- "field":"taskId"
+ "field":"sdkName.raw"
}
}
}
@@ -469,7 +469,7 @@
if !ok {
return nil, errors.New("first hits change error!")
}
- sdkName_status, ok := middle["sdkId_status"].(map[string]interface{})
+ sdkName_status, ok := middle["sdkName_status"].(map[string]interface{})
if !ok {
return nil, errors.New("first hits change error!")
}
@@ -481,9 +481,9 @@
fmt.Println("change to source error!")
continue
}
- sdkId := tmpbuf["key"].(string)
+ sdkName := tmpbuf["key"].(string)
count := int(tmpbuf["doc_count"].(float64))
- source["id"] = sdkId
+ source["name"] = sdkName
source["value"] = count
sources = append(sources, source)
}
--
Gitblit v1.8.0