MESURE DU COURENT

import paho.mqtt.client as mqtt
import mysql.connector
import json

db = mysql.connector.connect(
host="localhost", user="root", password="root", database="qos_mqtt"
)
cursor = db.cursor()

def on_message(client, userdata, message):
data = json.loads(message.payload.decode())
sql = "INSERT INTO mesures_sources (source, tension, courant, puissance, temperature) VALUES (%s,%s,%s,%s,%s)"
values = (data['source'], data['tension'], data['courant'], data['tension']*data['courant'], data['temperature'])
cursor.execute(sql, values)
db.commit()

client = mqtt.Client()
client.connect("localhost")
client.subscribe("energie/#", qos=1)
client.on_message = on_message
client.loop_forever()

The body contains a standalone Python script using paho-mqtt and mysql.connector, but it names no repository file, test, or requested change. First confirm whether this code is intended for influxdata/ui and clarify the expected behavior. There is currently no stated completion criterion.

Written by the indexing model from the issue text.