refactor: update sensor_data function to accept data directly instead of JSON string

This commit is contained in:
ishak jmilou.ishak
2025-01-09 14:29:54 +01:00
parent ed475cd19f
commit a4ae0170a0

View File

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