[agent]
  interval = "5s"
  round_interval = true
  metric_batch_size = 1000
  metric_buffer_limit = 10000
  collection_jitter = "0s"
  flush_interval = "5s"
  flush_jitter = "0s"
  debug=false

# Output Configuration for telegraf agent
[[outputs.influxdb_v2]]
  ## Point to your influxdb container
  urls = ["http://influxdb:8086"]
  ## Token for authentication; created with the influxdb_cli service.
  token = "7km_XYOmaTnOrCSt2MReAyGT-nWmG5lSfyiS8e9rn3jjLaDTEaJzsP7KdnHI9sReAGgmKSAKK98EWUrEAZ0EyA=="
  ## Organization is the name of the organization you wish to write to; created with the influxdb_cli service.
  organization = "milvert"
  # Destination bucket to write into; created with the influxdb_cli service.
  bucket = "MilvertBucket"
  namedrop = ["home", "electricity"]

[[outputs.influxdb_v2]]
  ## Point to your influxdb container
  urls = ["http://influxdb:8086"]
  ## Token for authentication; created with the influxdb_cli service.
  token = "G0KAflWQcbl-9OjDwGVwm-E7y3xchi4UBE_HWIzYwgt1IiB-mUZ0TXbCVCkSJyk7yXtDoedK2erQIQzbifIrsQ=="
  organization = "milvert"
  bucket = "HomeBucket"
  namepass = ["home", "el"]
  tagexclude = ["topic"]
  alias="Dummy"

#[[outputs.file]]
  #files = ["stdout", "/tmp/metrics.out"]

  #tagexclude = ["topic"]
  #namepass = ["home", "el"]
  #data_format = "influx"



[[inputs.http_listener_v2]]
  ## Address and port to host HTTP listener on
  service_address = ":8081"


  ## Path to listen to.
  path = "/write"

## HTTP methods to accept.
  methods = ["POST", "PUT"]

  data_format = "influx"

[[inputs.mqtt_consumer]]
  name_override = "el"
  servers = ["tcp://mqtt:1883"]
  username = "simon"
  password = "bajsa123"
  tagexclude = ["host"]
  topics = [
    "dsmr/reading/electricity_delivered",
    "dsmr/reading/electricity_delivered_1",
    "dsmr/reading/electricity_returned",
    "dsmr/reading/electricity_returned_1",
    "dsmr/reading/electricity_delivered_2",
    "dsmr/reading/electricity_returned_2",
    "dsmr/reading/electricity_currently_delivered",
    "dsmr/reading/electricity_currently_returned",
    "dsmr/reading/phase_currently_delivered_l1",
    "dsmr/reading/phase_currently_delivered_l2",
    "dsmr/reading/phase_currently_delivered_l3",
    "dsmr/reading/phase_currently_returned_l1",
    "dsmr/reading/phase_currently_returned_l2",
    "dsmr/reading/phase_currently_returned_l3",
    "dsmr/reading/phase_voltage_l1",
    "dsmr/reading/phase_voltage_l2",
    "dsmr/reading/phase_voltage_l3",
    "dsmr/reading/phase_power_current_l1",
    "dsmr/reading/phase_power_current_l2",
    "dsmr/reading/phase_power_current_l3",
    "dsmr/reading/electricity_hourly_usage"
  ]
  data_format = "value"
  data_type = "float"

  [[inputs.mqtt_consumer.topic_parsing]]
    topic = "dsmr/+/+"
    tags = "_/_/_field"

  [[processors.pivot]]
    tag_key = "_field"
    value_key = "value"