github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-11-21 14:44:00 +00:00
Code Issues Projects Releases Packages Wiki Activity

app/vmselect: mention the original query and time range in error messages

Browse source 
This should simplify debugging invalid or heavy queries.
This commit is contained in:
Aliaksandr Valialkin 2020-01-22 17:32:11 +02:00
parent f8954c7250
commit 9773022e50
2 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
app/vmselect/main.go
View file

@ -216,7 +216,7 @@ func RequestHandler(w http.ResponseWriter, r *http.Request) bool {
} }
func sendPrometheusError(w http.ResponseWriter, r *http.Request, err error) { func sendPrometheusError(w http.ResponseWriter, r *http.Request, err error) {
logger.Errorf("error in %q: %s", r.URL.Path, err) logger.Errorf("error in %q: %s", r.RequestURI, err)
w.Header().Set("Content-Type", "application/json") w.Header().Set("Content-Type", "application/json")
statusCode := http.StatusUnprocessableEntity statusCode := http.StatusUnprocessableEntity

12
app/vmselect/prometheus/prometheus.go
View file

@ -136,7 +136,7 @@ func ExportHandler(w http.ResponseWriter, r *http.Request) error {
end = start + defaultStep end = start + defaultStep
} }
if err := exportHandler(w, matches, start, end, format, deadline); err != nil { if err := exportHandler(w, matches, start, end, format, deadline); err != nil {
return err return fmt.Errorf("error when exporting data for queries=%q on the time range (start=%d, end=%d): %s", matches, start, end, err)
} }
exportDuration.UpdateDuration(startTime) exportDuration.UpdateDuration(startTime)
return nil return nil
@ -580,7 +580,7 @@ func QueryHandler(w http.ResponseWriter, r *http.Request) error {
end := start end := start
start = end - window start = end - window
if err := exportHandler(w, []string{childQuery}, start, end, "promapi", deadline); err != nil { if err := exportHandler(w, []string{childQuery}, start, end, "promapi", deadline); err != nil {
return err return fmt.Errorf("error when exporting data for query=%q on the time range (start=%d, end=%d): %s", childQuery, start, end, err)
} }
queryDuration.UpdateDuration(startTime) queryDuration.UpdateDuration(startTime)
return nil return nil
@ -605,7 +605,7 @@ func QueryHandler(w http.ResponseWriter, r *http.Request) error {
end := start end := start
start = end - window start = end - window
if err := queryRangeHandler(w, childQuery, start, end, step, r, ct); err != nil { if err := queryRangeHandler(w, childQuery, start, end, step, r, ct); err != nil {
return err return fmt.Errorf("error when executing query=%q on the time range (start=%d, end=%d, step=%d): %s", childQuery, start, end, step, err)
} }
queryDuration.UpdateDuration(startTime) queryDuration.UpdateDuration(startTime)
return nil return nil
@ -620,7 +620,7 @@ func QueryHandler(w http.ResponseWriter, r *http.Request) error {
} }
result, err := promql.Exec(&ec, query, true) result, err := promql.Exec(&ec, query, true)
if err != nil { if err != nil {
return fmt.Errorf("cannot execute %q: %s", query, err) return fmt.Errorf("error when executing query=%q for (time=%d, step=%d): %s", query, start, step, err)
} }
w.Header().Set("Content-Type", "application/json") w.Header().Set("Content-Type", "application/json")
@ -669,7 +669,7 @@ func QueryRangeHandler(w http.ResponseWriter, r *http.Request) error {
return err return err
} }
if err := queryRangeHandler(w, query, start, end, step, r, ct); err != nil { if err := queryRangeHandler(w, query, start, end, step, r, ct); err != nil {
return err return fmt.Errorf("error when executing query=%q on the time range (start=%d, end=%d, step=%d): %s", query, start, end, step, err)
} }
queryRangeDuration.UpdateDuration(startTime) queryRangeDuration.UpdateDuration(startTime)
return nil return nil
@ -707,7 +707,7 @@ func queryRangeHandler(w http.ResponseWriter, query string, start, end, step int
} }
result, err := promql.Exec(&ec, query, false) result, err := promql.Exec(&ec, query, false)
if err != nil { if err != nil {
return fmt.Errorf("cannot execute %q: %s", query, err) return fmt.Errorf("cannot execute query: %s", err)
} }
queryOffset := getLatencyOffsetMilliseconds() queryOffset := getLatencyOffsetMilliseconds()
if ct-end < queryOffset { if ct-end < queryOffset {