InfluxDB: Fix parsing multiple tags on backend mode (#77340)

* Multiple tags separated by comma in the result

* A non-flaky unit test
This commit is contained in:
ismail simsek 2023-10-30 15:45:20 +01:00 committed by GitHub
parent df3184a94a
commit 6b13064cf6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 41 additions and 0 deletions

View File

@ -258,6 +258,7 @@ func buildFrameNameFromQuery(row models.Row, column string, frameName []byte, re
first := true
for k, v := range row.Tags {
if !first {
frameName = append(frameName, ',')
frameName = append(frameName, ' ')
} else {
first = false

View File

@ -365,6 +365,46 @@ func TestInfluxdbResponseParser(t *testing.T) {
assert.Equal(t, "alias logins.count", result.Frames[1].Name)
})
t.Run("Influxdb response parser when multiple measurement in response", func(t *testing.T) {
response := `
{
"results": [
{
"series": [
{
"name": "cpu.upc",
"columns": ["time","mean"],
"tags": {
"datacenter": "America",
"cluster-name": "Cluster"
},
"values": [
[111,222]
]
},
{
"name": "logins.count",
"columns": ["time","mean"],
"tags": {
"datacenter": "America",
"cluster-name": "Cluster"
},
"values": [
[111,222]
]
}
]
}
]
}
`
query := models.Query{}
result := ResponseParse(prepare(response), 200, generateQuery(query))
assert.True(t, strings.Contains(result.Frames[0].Name, ","))
assert.True(t, strings.Contains(result.Frames[1].Name, ","))
})
t.Run("Influxdb response parser with alias", func(t *testing.T) {
response := `
{