diff --git a/pkg/tsdb/influxdb/model_parser.go b/pkg/tsdb/influxdb/model_parser.go index ff8977f925b..cbd4b397d9d 100644 --- a/pkg/tsdb/influxdb/model_parser.go +++ b/pkg/tsdb/influxdb/model_parser.go @@ -13,6 +13,7 @@ func (qp *InfluxdbQueryParser) Parse(model *simplejson.Json, dsInfo *tsdb.DataSo policy := model.Get("policy").MustString("default") rawQuery := model.Get("query").MustString("") interval := model.Get("interval").MustString("") + alias := model.Get("alias").MustString("") measurement := model.Get("measurement").MustString("") @@ -52,6 +53,7 @@ func (qp *InfluxdbQueryParser) Parse(model *simplejson.Json, dsInfo *tsdb.DataSo Selects: selects, RawQuery: rawQuery, Interval: interval, + Alias: alias, }, nil } diff --git a/pkg/tsdb/influxdb/model_parser_test.go b/pkg/tsdb/influxdb/model_parser_test.go index 8f43cc7d70f..eae6e163cc0 100644 --- a/pkg/tsdb/influxdb/model_parser_test.go +++ b/pkg/tsdb/influxdb/model_parser_test.go @@ -90,6 +90,7 @@ func TestInfluxdbQueryParser(t *testing.T) { } ] ], + "alias": "serie alias", "tags": [ { "key": "datacenter", @@ -115,6 +116,7 @@ func TestInfluxdbQueryParser(t *testing.T) { So(len(res.Selects), ShouldEqual, 3) So(len(res.Tags), ShouldEqual, 2) So(res.Interval, ShouldEqual, ">20s") + So(res.Alias, ShouldEqual, "serie alias") }) Convey("can part raw query json model", func() { diff --git a/pkg/tsdb/influxdb/models.go b/pkg/tsdb/influxdb/models.go index 7903616ff22..0dcecd20773 100644 --- a/pkg/tsdb/influxdb/models.go +++ b/pkg/tsdb/influxdb/models.go @@ -8,6 +8,7 @@ type Query struct { GroupBy []*QueryPart Selects []*Select RawQuery string + Alias string Interval string }