split the data

This commit is contained in:
ishak jmilou.ishak
2025-01-09 14:28:04 +01:00
parent a9c37ec470
commit ed475cd19f

View File

@@ -96,8 +96,11 @@ def database():
def sensor_data(kobuki_message): def sensor_data(kobuki_message):
db = get_db() db = get_db()
cursor = db.cursor() cursor = db.cursor()
sql_sensor = "INSERT INTO kobuki_data (data) VALUES (%s)" sql_sensor = "INSERT INTO kobuki_data (name, value) VALUES (%s)"
cursor.execute(sql_sensor, (kobuki_message,)) data_dict = json.loads(kobuki_message)
sensor_data_tuples = [(name, float(value))for name, value in data_dict.items()]
cursor.executemany(sql_sensor, sensor_data_tuples)
db.commit() db.commit()
cursor.close() cursor.close()