CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: add debug query output to elasticsearch_query (#9827)

This commit is contained in:
Joshua Powers 2021-09-29 07:50:44 -06:00 committed by GitHub
parent 56398237c4
commit e615534620
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
plugins/inputs/elasticsearch_query/aggregation_query.go
View File

@ -2,6 +2,7 @@ package elasticsearch_query
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"strings" "strings"
"time" "time"
@ -34,6 +35,16 @@ func (e *ElasticsearchQuery) runAggregationQuery(ctx context.Context, aggregatio
query = query.Filter(elastic5.NewQueryStringQuery(filterQuery)) query = query.Filter(elastic5.NewQueryStringQuery(filterQuery))
query = query.Filter(elastic5.NewRangeQuery(aggregation.DateField).From(from).To(now)) query = query.Filter(elastic5.NewRangeQuery(aggregation.DateField).From(from).To(now))
src, err := query.Source()
if err != nil {
return nil, fmt.Errorf("failed to get query source - %v", err)
}
data, err := json.Marshal(src)
if err != nil {
return nil, fmt.Errorf("failed to unmarshal response - %v", err)
}
e.Log.Debugf("{\"query\": %s}", string(data))
search := e.esClient.Search().Index(aggregation.Index).Query(query).Size(0) search := e.esClient.Search().Index(aggregation.Index).Query(query).Size(0)
// add only parent elastic.Aggregations to the search request, all the rest are subaggregations of these // add only parent elastic.Aggregations to the search request, all the rest are subaggregations of these