fixed variable name

This commit is contained in:
ishak jmilou.ishak
2025-01-09 14:06:13 +01:00
parent ec0b32a221
commit 331de940cc

View File

@@ -14,7 +14,6 @@ def on_message(client,userdata, message):
global kobuki_message, latest_image global kobuki_message, latest_image
if message.topic == "kobuki/data": if message.topic == "kobuki/data":
kobuki_message = str(message.payload.decode("utf-8")) kobuki_message = str(message.payload.decode("utf-8"))
save_sensor_data(kobuki_message)
elif message.topic == "kobuki/cam": elif message.topic == "kobuki/cam":
latest_image = message.payload latest_image = message.payload
@@ -78,9 +77,9 @@ def move():
sql_command = "INSERT INTO command (command) VALUES (%s)" sql_command = "INSERT INTO command (command) VALUES (%s)"
cursor.execute(sql_command, (direction,)) cursor.execute(sql_command, (direction,))
if data: if kobuki_message:
sql_sensor = "INSERT INTO kobuki_data (data) VALUES (%s)" sql_sensor = "INSERT INTO kobuki_data (data) VALUES (%s)"
sensor_data_tuples = [(name, value) for name, value in data.items()] sensor_data_tuples = [(name, value) for name, value in kobuki_message.items()]
cursor.executemany(sql_sensor, sensor_data_tuples) cursor.executemany(sql_sensor, sensor_data_tuples)
db_connection.commit() db_connection.commit()