wrote own functions for sending data

This commit is contained in:
ishak jmilou.ishak
2025-01-09 14:16:16 +01:00
parent 7560b0f67a
commit ec71028270

View File

@@ -91,14 +91,13 @@ def database():
cursor.close() cursor.close()
return str(rows) return str(rows)
def sensor_data(): def sensor_data(kobuki_message):
db = get_db() db = get_db()
cursor = db.cursor() cursor = db.cursor()
cursor.execute("SELECT * FROM kobuki_data") sql_sensor = "INSERT INTO kobuki_data (data) VALUES (%s)"
rows = cursor.fetchall() cursor.execute(sql_sensor, (kobuki_message,))
db.commit()
cursor.close() cursor.close()
return str(rows)
if __name__ == '__main__': if __name__ == '__main__':
app.run(debug=True, port=5000) app.run(debug=True, port=5000)