Alimentation de InfluxDB, via MQTT et Telegraf

Voici le paramétrage de Telegraf, pour alimenter InfluxDB. L'intérêt de Telegraph est de bufferiser les données en cas de coupure avec InfluxDB.

Dans l'agent Telegraf on a :

metric_buffer_limit = 10000
flush_interval = "10s"

metric_buffer_limit = 10000 : Telegraf va stocker jusqu’à 10 000 points en mémoire avant de commencer à jeter les anciens si le buffer est plein.

flush_interval = "10s" : Telegraf tente d’envoyer les données toutes les 10 secondes vers InfluxDB.

Donc, si InfluxDB est indisponible, Telegraf va mettre les mesures en mémoire jusqu’à atteindre 10 000 points.

2️⃣ Comportement en cas de coupure

Courte coupure (< buffer) : Les données sont stockées dans le buffer et seront envoyées dès que InfluxDB redevient disponible.

Coupure longue (> buffer) : Une fois que le buffer de 10 000 points est rempli, les nouvelles données sont perdues, Telegraf ne peut pas les retenir indéfiniment en mémoire (possibilité de flusher sur disque si besoin).

# -------------------------------
# Configuration de l'agent Telegraf
# -------------------------------
[agent]
  debug = true
  logfile = ""
  interval = "10s"
  round_interval = true
  metric_batch_size = 1000
  metric_buffer_limit = 10000
  collection_jitter = "0s"
  flush_interval = "10s"
  flush_jitter = "0s"
  precision = ""
  hostname = ""
  omit_hostname = false
  # skip_processors_after_aggregators = false  # option pour v1.40+

# Ici on envoie les données collectées dans InfluxDB
# -------------------------------
# Output vers InfluxDB v2
# -------------------------------
[[outputs.influxdb_v2]]
  urls = ["http://192.168.1.246:8086"]
  token = "$INFLUX_TOKEN"
  organization = "mv"
  bucket = "ruche"


# ici on récupère tous les topics qui ont été envoyés dans MQTT par l'ESP32
# -------------------------------
# Input MQTT - tous les topics
# -------------------------------
[[inputs.mqtt_consumer]]
  servers = ["tcp://192.168.1.249:1883"]
  username = "telegraf"
  password = "dbraux"
  topics = ["#"]
  client_id = "telegraf-proxmox"
  qos = 1
  persistent_session = false
  connection_timeout = "30s"
  data_format = "value"
  data_type = "float"