From e1358eeb7671fffe311c51dc9dbbb8504c698530 Mon Sep 17 00:00:00 2001 From: Alexander Emelin Date: Sat, 10 Jul 2021 16:46:21 +0300 Subject: [PATCH] live: better error logging in push API (#36601) --- 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 59ee360757d..8ccf828f77f 100644 --- a/pkg/services/live/pushhttp/push.go +++ b/pkg/services/live/pushhttp/push.go @@ -89,6 +89,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 } }