The following is my configuration：
AMQP consumer plugin
[[inputs.amqp_consumer]]
AMQP url
url = “amqp://localhost:5672/influxdb”
AMQP exchange
exchange = “telegraf”
AMQP queue name
queue = “mytest”
Binding Key
binding_key = “hello”
Controls how many messages the server will try to keep on the network
for consumers before receiving delivery acks.
#prefetch_count = 50
Auth method. PLAIN and EXTERNAL are supported.
Using EXTERNAL requires enabling the rabbitmq_auth_mechanism_ssl plugin as
described here: Plugins — RabbitMQ
auth_method = “PLAIN”
Optional SSL Config
ssl_ca = “/etc/telegraf/ca.pem”
ssl_cert = “/etc/telegraf/cert.pem”
ssl_key = “/etc/telegraf/key.pem”
Use SSL but skip chain & host verification
insecure_skip_verify = false
Data format to output.
Each data format has its own unique set of configuration options, read
more about them here:
telegraf/DATA_FORMATS_OUTPUT.md at master · influxdata/telegraf · GitHub
data_format = “influx”
Start telegraf service prompt information：
2017/05/09 11:37:33 E! Error parsing telegraf.conf, Undefined but requested input: amqp_consumer.
Please enlighten！Thanks very much
