From 6597287fc412ce914aba41fe571ed05817cf371c Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期一, 27 五月 2024 11:34:58 +0800
Subject: [PATCH] fix script
---
db/elastic.go | 11 +++++------
1 files changed, 5 insertions(+), 6 deletions(-)
diff --git a/db/elastic.go b/db/elastic.go
index ba4bbcb..5e638c9 100644
--- a/db/elastic.go
+++ b/db/elastic.go
@@ -4,7 +4,6 @@
"basic.com/pubsub/esutil.git"
"basic.com/valib/logger.git"
"encoding/json"
- "fmt"
"ruleModelEngine/config"
"ruleModelEngine/util"
"strconv"
@@ -121,8 +120,8 @@
}
}
}`
- fmt.Println(queryDSL)
- fmt.Println(esURL)
+ //fmt.Println(queryDSL)
+ //fmt.Println(esURL)
docNumberMap := make(map[string]string)
buf, err := esutil.EsReq("POST", esURL, []byte(queryDSL))
if err != nil {
@@ -132,7 +131,7 @@
if err != nil {
return nil, err
}
- fmt.Println("source", source)
+ //fmt.Println("source", source)
for _, info := range source {
buckets := info["top_hits"].(map[string]interface{})["hits"].(map[string]interface{})["hits"].([]interface{})
for _, sourceInfo := range buckets {
@@ -259,8 +258,8 @@
logger.Info("鏈湁棰勮 id: ", id)
return true, nil
}
- fmt.Println("棰勮 id: ", id)
- fmt.Println("棰勮 AlarmRule: ", alarmRules)
+ logger.Info("棰勮 id: ", id)
+ logger.Info("棰勮 AlarmRule: ", alarmRules)
esURL := "http://" + config.Elastic.Host + ":" + config.Elastic.Port + "/" + config.Elastic.Index + "/_update_by_query"
newAlarmRulesJson, err := json.Marshal(alarmRules)
if err != nil {
--
Gitblit v1.8.0