From 6eaaf713ab1b73f3efa22df5ad8e8645b7c52a11 Mon Sep 17 00:00:00 2001 From: liuxiaolong <736321739@qq.com> Date: 星期一, 28 十月 2019 19:44:32 +0800 Subject: [PATCH] AggregateTaskList filter analyServerId if need --- EsApi.go | 20 ++++++++++++++++++-- 1 files changed, 18 insertions(+), 2 deletions(-) diff --git a/EsApi.go b/EsApi.go index 62ea6cd..3eda422 100644 --- a/EsApi.go +++ b/EsApi.go @@ -693,9 +693,24 @@ } //鑱氬悎浠诲姟鍒楄〃锛宼askId+taskName -func AggregateTaskList(serverIp string, serverPort string, indexName string) (sources []map[string]interface{},err error){ +func AggregateTaskList(serverIp string, serverPort string, indexName string, analyServerId string) (sources []map[string]interface{},err error){ url := "http://" + serverIp + ":" + serverPort + "/"+indexName+"/_search" + serverFilterStr := "" + if analyServerId != "" { + serverFilterStr = `, + "query": { + "bool": { + "filter": [ + { + "term": { + "analyServerId": "`+analyServerId+`" + } + } + ] + } + }` + } DSLJson := `{ "size": 0, "aggs": { @@ -717,10 +732,11 @@ } } ], - "size":"1000" + "size":"100000000" } } } + `+serverFilterStr+` }` buf, err := EsReq("POST",url,[]byte(DSLJson)) if err != nil { -- Gitblit v1.8.0