| | |
|---|
| | | "basic.com/pubsub/esutil.git" |
|---|
| | | "basic.com/valib/logger.git" |
|---|
| | | "encoding/json" |
|---|
| | | "fmt" |
|---|
| | | "ruleModelEngine/config" |
|---|
| | | "ruleModelEngine/util" |
|---|
| | | "strconv" |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }` |
|---|
| | | 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 { |
|---|
| | |
|---|
| | | 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 { |
|---|
| | |
|---|
| | | 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 { |
|---|
