From d673a6178a172cda46473075ed466ec062c90a64 Mon Sep 17 00:00:00 2001 From: sunty <1172534965@qq.com> Date: 星期三, 16 九月 2020 15:06:47 +0800 Subject: [PATCH] upgrade RealTimeAlarmTaskRate sdkName to taskName --- EsApi.go | 9 ++++----- 1 files changed, 4 insertions(+), 5 deletions(-) diff --git a/EsApi.go b/EsApi.go index 64235bf..1ee9b4c 100644 --- a/EsApi.go +++ b/EsApi.go @@ -1195,7 +1195,6 @@ } } }` - //logPrint(DSLJson) buf, err := EsReq("POST", url, []byte(DSLJson)) if err != nil { return total, err @@ -1233,9 +1232,9 @@ } }, "aggs":{ - "sdkName_status":{ + "taskName_status":{ "terms":{ - "field":"sdkName.raw" + "field":"taskName.raw" } } } @@ -1254,11 +1253,11 @@ if !ok { return nil, errors.New("first hits change error!") } - sdkName_status, ok := middle["sdkName_status"].(map[string]interface{}) + sdkName_status, ok := middle["taskName_status"].(map[string]interface{}) if !ok { return nil, errors.New("first hits change error!") } - + //fmt.Println(sdkName_status) for _, in := range sdkName_status["buckets"].([]interface{}) { var source = make(map[string]interface{}, 0) tmpbuf, ok := in.(map[string]interface{}) -- Gitblit v1.8.0