From d11e65d3ac9cc21621c6740690705261a583140a Mon Sep 17 00:00:00 2001 From: "Grot (@grafanabot)" <43478413+grafanabot@users.noreply.github.com> Date: Tue, 13 Jul 2021 13:43:15 +0200 Subject: [PATCH] live: better error logging in push API (#36601) (#36623) (cherry picked from commit e1358eeb7671fffe311c51dc9dbbb8504c698530) Co-authored-by: Alexander Emelin --- pkg/services/live/pushhttp/push.go | 1 + pkg/services/live/pushws/push.go | 1 + 2 files changed, 2 insertions(+) diff --git a/pkg/services/live/pushhttp/push.go b/pkg/services/live/pushhttp/push.go index e6df5471186..28aa2ca4e29 100644 --- a/pkg/services/live/pushhttp/push.go +++ b/pkg/services/live/pushhttp/push.go @@ -88,6 +88,7 @@ func (g *Gateway) Handle(ctx *models.ReqContext) { for _, mf := range metricFrames { err := stream.Push(ctx.SignedInUser.OrgId, mf.Key(), mf.Frame()) if err != nil { + logger.Error("Error pushing frame", "error", err, "data", string(body)) ctx.Resp.WriteHeader(http.StatusInternalServerError) return } diff --git a/pkg/services/live/pushws/push.go b/pkg/services/live/pushws/push.go index bf50e9e8b89..c41092b0cb9 100644 --- a/pkg/services/live/pushws/push.go +++ b/pkg/services/live/pushws/push.go @@ -191,6 +191,7 @@ func (s *Handler) ServeHTTP(rw http.ResponseWriter, r *http.Request) { for _, mf := range metricFrames { err := stream.Push(user.OrgId, mf.Key(), mf.Frame()) if err != nil { + logger.Error("Error pushing frame", "error", err, "data", string(body)) return } }