mirror of
https://gitlab.fdmci.hva.nl/technische-informatica-sm3/ti-projectten/rooziinuubii79.git
synced 2025-08-03 20:04:58 +00:00
commented sensor data
This commit is contained in:
@@ -14,8 +14,8 @@ def on_message(client,userdata, message):
|
||||
global kobuki_message, latest_image
|
||||
if message.topic == "kobuki/data":
|
||||
kobuki_message = str(message.payload.decode("utf-8"))
|
||||
with app.app_context():
|
||||
sensor_data() # Sla de data op in de database
|
||||
# with app.app_context():
|
||||
# sensor_data() # Sla de data op in de database
|
||||
elif message.topic == "kobuki/cam":
|
||||
latest_image = message.payload
|
||||
|
||||
@@ -94,16 +94,16 @@ def database():
|
||||
cursor.close()
|
||||
return str(rows)
|
||||
|
||||
def sensor_data():
|
||||
data = request.get_json()
|
||||
db = get_db()
|
||||
cursor = db.cursor()
|
||||
sql_sensor = "INSERT INTO kobuki_data (name, value) VALUES (%s)"
|
||||
sensor_data_tuples = [(name, float(value))for name, value in data.items()]
|
||||
cursor.executemany(sql_sensor, sensor_data_tuples)
|
||||
# def sensor_data():
|
||||
# data = request.get_json()
|
||||
# db = get_db()
|
||||
# cursor = db.cursor()
|
||||
# sql_sensor = "INSERT INTO kobuki_data (name, value) VALUES (%s)"
|
||||
# sensor_data_tuples = [(name, float(value))for name, value in data.items()]
|
||||
# cursor.executemany(sql_sensor, sensor_data_tuples)
|
||||
|
||||
db.commit()
|
||||
cursor.close()
|
||||
# db.commit()
|
||||
# cursor.close()
|
||||
|
||||
if __name__ == '__main__':
|
||||
app.run(debug=True, port=5000)
|
||||
|
Reference in New Issue
Block a user