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

Updated kinesis plugin to support json format

This commit is contained in:
alessandrodd 2016-11-11 10:16:04 +01:00 committed by GitHub
parent 15660367e3
commit bd7567380b
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
plugins/outputs/kinesis/kinesis.go
View File

@ -1,12 +1,12 @@
package kinesis
import (
ejson "encoding/json"
"fmt"
"log"
"os"
"sync/atomic"
"time"
ejson "encoding/json"
"github.com/aws/aws-sdk-go/aws"
"github.com/aws/aws-sdk-go/service/kinesis"
@ -129,17 +129,17 @@ func (k *KinesisOutput) Close() error {
func FormatMetric(k *KinesisOutput, point telegraf.Metric) (string, error) {
if k.Format == "string" {
return point.String(), nil
}
if k.Format == "json"{
m := make(map[string]interface{})
m["tags"] = point.Tags()
m["fields"] = point.Fields()
m["name"] = point.Name()
m["timestamp"] = point.UnixNano() / 1000000000
serialized, err := ejson.Marshal(m)
if err != nil {
return "", err
}
}
if k.Format == "json" {
m := make(map[string]interface{})
m["tags"] = point.Tags()
m["fields"] = point.Fields()
m["name"] = point.Name()
m["timestamp"] = point.UnixNano() / 1000000000
serialized, err := ejson.Marshal(m)
if err != nil {
return "", err
}
return string(serialized), nil
}