| | |
| | | } |
| | | |
| | | //综合统计 |
| | | func StatisticsComprehensive(serverIp string, serverPort string, indexName string) (total int, err error){ |
| | | func StatisticsComprehensive(serverIp string, serverPort string, indexName string, isAlarm bool) (total int, err error){ |
| | | isAlarmStr := "" |
| | | if isAlarm == true { |
| | | isAlarmStr = `,{"term":{"isAlarm":1}}` |
| | | } |
| | | url := "http://" + serverIp + ":" + serverPort + |
| | | "/" + indexName + "/_search" |
| | | DSLJson := `{ |
| | |
| | | "filter":[{ |
| | | "range":{ |
| | | "picDate":{ |
| | | "gte":"now+8H/d" |
| | | "gte":"now+8h/d" |
| | | } |
| | | } |
| | | }] |
| | | } |
| | | `+isAlarmStr+` |
| | | ] |
| | | } |
| | | } |
| | | }` |
| | | //fmt.Println(DSLJson) |
| | | buf, err := EsReq("POST",url,[]byte(DSLJson)) |
| | | if err != nil { |
| | | return total, err |
| | |
| | | //fmt.Println(total) |
| | | return total,nil |
| | | } |
| | | |
| | | //实时报警任务比率 |
| | | func RealTimeAlarmTaskRate(serverIp string, serverPort string, indexName string) (sources []map[string]interface{},err error){ |
| | | url := "http://" + serverIp + ":" + serverPort + |