| | |
| | | "size": 0, |
| | | } |
| | | |
| | | query = map[string]interface{}{ |
| | | "query": map[string]interface{}{ |
| | | "bool": map[string]interface{}{ |
| | | "filter": filters, |
| | | }, |
| | | }, |
| | | "size": 10000, |
| | | } |
| | | if err := json.NewEncoder(&buf).Encode(query); err != nil { |
| | | return nil, fmt.Errorf("error encoding query: %s", err) |
| | | } |
| | |
| | | if err := json.NewDecoder(res.Body).Decode(&result); err != nil { |
| | | return nil, fmt.Errorf("error parsing response body: %s", err) |
| | | } |
| | | |
| | | logger.Debugf("ressss--------------------------------------- %s", result) |
| | | // 解析聚合结果 |
| | | var records []*LocationRecord |
| | | if aggs, ok := result["aggregations"].(map[string]interface{}); ok { |