From d7cb7d5ffa3e7ba7e13d40afd50b848c3717d5ef Mon Sep 17 00:00:00 2001 From: Kelvin Wang Date: Fri, 26 Apr 2019 12:49:45 -0400 Subject: [PATCH] fix(gather): add bkt and org id to scraper writer --- gather/recorder.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/gather/recorder.go b/gather/recorder.go index dcdc4c8424..9b09f289f9 100644 --- a/gather/recorder.go +++ b/gather/recorder.go @@ -6,6 +6,7 @@ import ( "github.com/influxdata/influxdb/nats" "github.com/influxdata/influxdb/storage" + "github.com/influxdata/influxdb/tsdb" "go.uber.org/zap" ) @@ -20,6 +21,11 @@ func (s PointWriter) Record(collected MetricsCollection) error { if err != nil { return err } + ps, err = tsdb.ExplodePoints(collected.OrgID, collected.BucketID, ps) + if err != nil { + return err + } + return s.Writer.WritePoints(context.TODO(), ps) }