influxdata / telegraf

Agent for collecting, processing, aggregating, and writing metrics, logs, and other arbitrary data.
https://influxdata.com/telegraf
MIT License
14.53k stars 5.56k forks source link

Telegraf AMQP plugin error - parsing issue #15942

Open kk010100 opened 2 days ago

kk010100 commented 2 days ago

Relevant telegraf.conf

[[inputs.amqp_consumer]]

   brokers = ["amqp://localhost:5672/MQTT"]
#
#   ## Authentication credentials for the PLAIN auth_method.
    username = "a"
    password = "b"
#
#   ## Name of the exchange to declare.  If unset, no exchange will be declared.
   exchange = "telegraf"

#   ## AMQP queue name.
   queue = "telegraf"
#
#   ## AMQP queue durability can be "transient" or "durable".
   queue_durability = "durable"

#   ## A binding between the exchange and queue using this binding key is
#   ## created.  If unset, no binding is created.
   binding_key = "#"

data_format = "json"

json_time_key = "date"
json_time_format = "2024-09-26-10:00:00"

Logs from Telegraf

telegraf[79603]: 2024-09-26T14:39:41Z E! [inputs.amqp_consumer] Error in plugin: invalid character '-' after object key:value pair

System info

Telegraf 1.32.0, Ubuntu 24.04.1 LTS

Docker

No response

Steps to reproduce

1.MQTT stores data in RabbitMQ 2.Data = {"date": 2024-09-26-05:46:16,"location":position_33,"ms1":19.9025,"ms2":1139.0} 3.Telegraf reads stored data and returns error. ...

Expected behavior

Data should go into influxdb. If Telegraf can't parse this field as datetime at least it should store it as string.

Actual behavior

Data is not being written to InfluxDB. Error is returned: telegraf[79603]: 2024-09-26T14:39:41Z E! [inputs.amqp_consumer] Error in plugin: invalid character '-' after object key:value pair

Is there something I'm missing in the configuration? Seem's like very basic problem, but I can't get it to pass the data to InfluxDB from RabbitMQ using AMQP protocol.

Additional info

No response