diff --git a/src/Python/flask/web/app.py b/src/Python/flask/web/app.py index 3dd5d30..54db722 100644 --- a/src/Python/flask/web/app.py +++ b/src/Python/flask/web/app.py @@ -96,8 +96,11 @@ def database(): def sensor_data(kobuki_message): db = get_db() cursor = db.cursor() - sql_sensor = "INSERT INTO kobuki_data (data) VALUES (%s)" - cursor.execute(sql_sensor, (kobuki_message,)) + 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_dict.items()] + cursor.executemany(sql_sensor, sensor_data_tuples) + db.commit() cursor.close()