From 801f4b3ef1789e9f167a9267825a8308230fcd5f Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期二, 27 七月 2021 14:45:04 +0800
Subject: [PATCH] add total on deldata
---
EsApi.go | 15 ++++++---------
1 files changed, 6 insertions(+), 9 deletions(-)
diff --git a/EsApi.go b/EsApi.go
index 7fcb74c..dd058d8 100644
--- a/EsApi.go
+++ b/EsApi.go
@@ -1638,7 +1638,7 @@
}
//鎸夋棩鏈熻寖鍥达紝鏈嶅姟鍣↖d鍒犻櫎鏁版嵁
-func DeleteAnalyServerData(serverIp string, serverPort string, indexName string, startTime string, endTime string, analyServerId string) (result bool, err error) {
+func DeleteAnalyServerData(serverIp string, serverPort string, indexName string, startTime string, endTime string, analyServerId string) (total int, err error,) {
url := "http://" + serverIp + ":" + serverPort + "/" + indexName + "/_delete_by_query"
deleteJson := `{
"query":{
@@ -1660,20 +1660,17 @@
}
}
} `
+ fmt.Println(url)
+ fmt.Println(deleteJson)
buf, err := EsReq("POST", url, []byte(deleteJson))
if err != nil {
- return false, errors.New("璇锋眰澶辫触")
+ return -1, errors.New("璇锋眰澶辫触")
}
deleteRes, err := SourceDeleted(buf)
if err != nil {
- return false, errors.New("瑙ｇ爜澶辫触")
+ return -1, errors.New("瑙ｇ爜澶辫触")
}
- if deleteRes == -1 {
- result = false
- } else {
- result = true
- }
- return result, nil
+ return deleteRes,nil
}
//缁欐墍鏈夎妭鐐硅拷鍔犲垹闄や换鍔′俊鎭�
--
Gitblit v1.8.0