dom
/
telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Remove the columns used as tag

This commit is contained in:
Thomas Menard 2016-03-17 15:01:08 +01:00
parent 7e09f3add1
commit fe8593b9a1
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
plugins/inputs/postgresql_extensible/postgresql_extensible.go
View File

@ -241,14 +241,16 @@ func (p *Postgresql) accRow(row scanner, acc telegraf.Accumulator) error {
tags := map[string]string{} tags := map[string]string{}
tags["server"] = tagAddress tags["server"] = tagAddress
tags["db"] = dbname.String() tags["db"] = dbname.String()
var isATag int
fields := make(map[string]interface{}) fields := make(map[string]interface{})
for col, val := range columnMap { for col, val := range columnMap {
_, ignore := ignoredColumns[col] _, ignore := ignoredColumns[col]
//if !ignore && *val != "" { //if !ignore && *val != "" {
if !ignore { if !ignore {
isATag = 0
for tag := range p.AdditionalTags { for tag := range p.AdditionalTags {
if col == p.AdditionalTags[tag] { if col == p.AdditionalTags[tag] {
isATag = 1
value_type_p := fmt.Sprintf(`%T`, *val) value_type_p := fmt.Sprintf(`%T`, *val)
if value_type_p == "[]uint8" { if value_type_p == "[]uint8" {
tags[col] = fmt.Sprintf(`%s`, *val) tags[col] = fmt.Sprintf(`%s`, *val)
@ -257,7 +259,9 @@ func (p *Postgresql) accRow(row scanner, acc telegraf.Accumulator) error {
} }
} }
} }
fields[col] = *val if isATag == 0 {
fields[col] = *val
}
} }
} }
acc.AddFields("postgresql", fields, tags) acc.AddFields("postgresql", fields, tags)