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

adding the tags in the graylog output plugin 

closes #1861
This commit is contained in:
Edie Zhang 2016-10-07 11:47:23 +11:00 committed by Cameron Sparr
parent 7f0fe78615
commit 4f06f6b3d8
2 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGELOG.md
View File

@ -11,6 +11,7 @@ continue sending logs to /var/log/telegraf/telegraf.log.
### Features ### Features
- [#1861](https://github.com/influxdata/telegraf/pull/1861): adding the tags in the graylog output plugin
- [#1732](https://github.com/influxdata/telegraf/pull/1732): Telegraf systemd service, log to journal. - [#1732](https://github.com/influxdata/telegraf/pull/1732): Telegraf systemd service, log to journal.
- [#1782](https://github.com/influxdata/telegraf/pull/1782): Allow numeric and non-string values for tag_keys. - [#1782](https://github.com/influxdata/telegraf/pull/1782): Allow numeric and non-string values for tag_keys.
- [#1694](https://github.com/influxdata/telegraf/pull/1694): Adding Gauge and Counter metric types. - [#1694](https://github.com/influxdata/telegraf/pull/1694): Adding Gauge and Counter metric types.

9
plugins/outputs/graylog/graylog.go
View File

@ -226,9 +226,14 @@ func serialize(metric telegraf.Metric) ([]string, error) {
m["host"] = host m["host"] = host
} }
for key, value := range metric.Tags() {
if key != "host" {
m["_"+key] = value
}
}
for key, value := range metric.Fields() { for key, value := range metric.Fields() {
nkey := fmt.Sprintf("_%s", key) m["_"+key] = value
m[nkey] = value
} }
serialized, err := ejson.Marshal(m) serialized, err := ejson.Marshal(m)