0_input_mqtt.json

{
  "si_temp": 20.19,
  "si_humidity": 40.91,
  "si_co2": 413,
  "name": "Office 1",
  "metadata": {
    "time": "2019-01-09T10:15:00.251888176Z",
    "modulation": "LORA",
    "gateways": [
      {
        "timestamp": 4103837484,
        "time": "2019-01-09T10:15:00.217853Z",
        "snr": -6.2,
        "rssi": -107,
        "rf_chain": 1,
        "longitude": 9.750678,
        "location_source": "registry",
        "latitude": 47.388233,
        "gtw_id": "eui-0012fcc23d0e1e26",
        "channel": 1
      }
    ],
    "frequency": 868.3,
    "data_rate": "SF12BW125",
    "coding_rate": "4/5",
    "airtime": 1318912000
  }
}

1_output_elastic.json

{
  "_index": "telegraf-2019.01.09",
  "_type": "metrics",
  "_id": "Vc0bMmgBZXCt_HmbyGNX",
  "_version": 1,
  "_score": null,
  "_source": {
    "@timestamp": "2019-01-09T10:15:00.500893511Z",
    "Office 1": {
      "metadata_airtime": 1318912000,
      "metadata_frequency": 868.3,
      "metadata_gateways_0_channel": 1,
      "metadata_gateways_0_latitude": 47.388233,
      "metadata_gateways_0_longitude": 9.750678,
      "metadata_gateways_0_rf_chain": 1,
      "metadata_gateways_0_rssi": -107,
      "metadata_gateways_0_snr": -6.2,
      "metadata_gateways_0_timestamp": 4103837484,
      "si_co2": 413,
      "si_humidity": 40.91,
      "si_temp": 20.19
    },
    "measurement_name": "Office 1",
    "tag": {
      "host": "1893703501d2",
      "topic": "events"
    }
  },
  "fields": {
    "@timestamp": [
      "2019-01-09T10:15:00.500Z"
    ]
  },
  "sort": [
    1547028900500
  ]
}

telegraf.conf

[global_tags]

[agent]
  interval = "10s"
  round_interval = true
  metric_buffer_limit = 10000
  flush_buffer_when_full = true
  collection_jitter = "0s"
  flush_interval = "10s"
  flush_jitter = "0s"
  debug = false
  quiet = false
  hostname = ""
  
[[outputs.elasticsearch]]
  urls = [ "http://elasticsearch:9200" ] # required.
  timeout = "5s"
  enable_sniffer = false
  health_check_interval = "10s"
  index_name = "telegraf-%Y.%m.%d" # required.
  manage_template = true
  template_name = "telegraf"
  overwrite_template = false
  
[[outputs.influxdb]]
  urls = ["http://influxdb:8086"] # required
  database = "telegraf" # required
  precision = "s"
  timeout = "5s"

[[inputs.mqtt_consumer]]
  servers = ["tcp://mqtt:1883"]
  qos = 0
  connection_timeout = "30s"
  topics = [ "events" ]
  persistent_session = false
  client_id = "telegraf01"
  data_format = "json"
  json_name_key = "name"