telegraf configuration file that connects to Mosquitto Open broker and pushes data into InfluxDB v1.x

commands-docker.sh

# For Telegraf v1.13
docker run --name=telegrafv1.13 -v $pwd/telegraf.conf:/etc/telegraf.conf:ro --net=host telegraf:1.13

# For Telegraf v1.15
docker run --name=telegrafv1.15 -v $pwd/telegraf.conf/etc/telegraf.conf:ro --net=host telegraf:1.15

LineProtocolPayload.txt

# IOT/sensor2/temp
env,type=A temp=23.39
env,type=B temp=40.00

# IOT/sensor1/acc
env,type=A x=0.2
env,type=B x=1.3

MQTT.fx.json

{
  "publishTopics": [
    {
      "name": "IOT/sensor1/acc"
    },
    {
      "name": "IOT/sensor2/temp"
    }
  ]
}

telegraf.conf

[agent]
    interval = "20s"
    round_interval = true
    metric_batch_size = 1000
    metric_buffer_limit = 10000
    collection_jitter = "0s"
    flush_interval = "10s"
    flush_jitter = "0s"
    precision = ""
    debug = true
    quiet = false
    hostname = ""
    omit_hostname = true

#############################################################
#                   OUTPUT PLUGINS                          #
#############################################################
[[outputs.influxdb]]
    urls = [ "http://influxdb:8086" ]

    database = "mqtelegraftest"

    skip_database_creation = false

    timeout = "5s"

###############################################################
#                   PROCESSOR PLUGINS                         #
###############################################################

[[processors.regex]]

    order = 1
    
    [[processors.regex.tags]]

        # use the `topic` tag to extract information from the MQTT Topic
        key = "topic"
        # Topic: IOT/<SENSOR_ID>/<measurement>
        # Extract <SENSOR_ID>
        pattern = ".*/(.*)/.*"
        # Replace the first occurrence
        replacement = "${1}"
        # Store it in tag called:
        result_key = "sensorID"

[[processors.enum]]

    order = 2
    
    [[processors.enum.mapping]]

        # create a mapping between extracted sensorID and some meta-data
        tag = "sensorID"
        dest = "location"

        [processors.enum.mapping.value_mappings]
            "sensor1" = "kitchen"
            "sensor2" = "livingroom"
            "sensor3" = "bedroom"

##################################################################
#                   INPUT PLUGINS                                #
##################################################################

[[inputs.mqtt_consumer]]

    servers = [ "tcp://test.mosquitto.org:1883" ]

    # Topics to subscribe to:
    topics = [
        "IOT/+/acc",
        "IOT/+/mag",
        "IOT/+/gyro",
        "IOT/+/temp"
    ]

    # Telegraf will also store the topic as a tag with name `topic`
    # NOTE: necessary for the Processor REGEX to extract <Sensor_ID>
    topic_tag = "topic"

    # Connection timeout
    connection_timeout = "30s"

    # Incoming MQTT Payload from Sensor nodes is in InfluxDB Line Protocol strings
    data_format = "influx"