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