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

Remove the columns used as tag

Browse Source 
closes #844
This commit is contained in:
Thomas Menard
2016-03-17 15:01:08 +01:00
committed by Cameron Sparr
parent b371ec5cf6
commit 36446bcbc2
3 changed files with 192 additions and 15 deletions
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["server"] = tagAddress
tags["db"] = dbname.String()
var isATag int
fields := make(map[string]interface{})
for col, val := range columnMap {
_, ignore := ignoredColumns[col]
//if !ignore && *val != "" {
if !ignore {
isATag = 0
for tag := range p.AdditionalTags {
if col == p.AdditionalTags[tag] {
isATag = 1
value_type_p := fmt.Sprintf(`%T`, *val)
if value_type_p == "[]uint8" {
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)