Automating MQTT Message Parsing


I’d like to automate the mqtt parsing.

Such as;
A topic /database/measurement will send all data received under that topic to the database and measurement mentioned in the topic name.

So I can use one parser to automate 1.000 iot nodes to use mqtt as a central broker without a configuration in telegraf.

Can I do that?


Have you tried utilizing influxdb output’s database_tag to dynamically send metrics to a database?

How can I get the “YYY” as a parameter for this tag from mqtt.consumer where the topic is /XXX/YYY ?


Perhaps the strings processor to strip /XXX/

Can you provide an example configuration including mqtt_consumer, processor and influxdb.output?