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

MQTT Consumer Input plugin

Browse Source
This commit is contained in:
Cameron Sparr
2016-02-09 15:03:46 -07:00
committed by Michele Fadda
parent 6b0ea64d1b
commit 668e16bb36
16 changed files with 554 additions and 44 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
plugins/inputs/nats_consumer/README.md
View File

@@ -1,14 +1,15 @@
# NATS Consumer
# NATS Consumer Input Plugin
The [NATS](http://www.nats.io/about/) consumer plugin reads from
The [NATS](http://www.nats.io/about/) consumer plugin reads from
specified NATS subjects and adds messages to InfluxDB. The plugin expects messages
in the [Telegraf Input Data Formats](https://github.com/influxdata/telegraf/blob/master/DATA_FORMATS_INPUT.md).
in the [Telegraf Input Data Formats](https://github.com/influxdata/telegraf/blob/master/DATA_FORMATS_INPUT.md).
A [Queue Group](http://www.nats.io/documentation/concepts/nats-queueing/)
is used when subscribing to subjects so multiple instances of telegraf can read
from a NATS cluster in parallel.
## Configuration
```
```toml
# Read metrics from NATS subject(s)
[[inputs.nats_consumer]]
### urls of NATS servers
@@ -21,18 +22,10 @@ from a NATS cluster in parallel.
queue_group = "telegraf_consumers"
### Maximum number of metrics to buffer between collection intervals
metric_buffer = 100000
### Data format to consume. This can be "json", "influx" or "graphite"
### Each data format has it's own unique set of configuration options, read
### more about them here:
### https://github.com/influxdata/telegraf/blob/master/DATA_FORMATS_INPUT.md
data_format = "influx"
```
## Testing
To run tests:
```
go test
```