Merge branch 'main' into mohammed

index.py

@@ -2,65 +2,68 @@ import mysql.connector
 import requests
 import time
 
-while True:
-    try:
-        # API-verzoek
-        url = "https://garden.inajar.nl/api/battery_voltage_events/?format=json"
-        headers = {
-            "Authorization": "Token 33bb3b42452306c58ecedc3c86cfae28ba22329c"
-        }
 
-        response = requests.get(url, headers=headers)
-        response.raise_for_status()
 
-        data = response.json().get('results', [])
+def database_connect():
+    return mysql.connector.connect(
+        host="localhost",
+        user="root",
+        password="",
+        database="goodgarden"
+    )
 
-        print("API-reactie:")
-        print(data)
+def fetch_data():
+    url = "https://garden.inajar.nl/api/battery_voltage_events/?format=json"
+    headers = {
+        "Authorization": "Token 33bb3b42452306c58ecedc3c86cfae28ba22329c"
+    }
 
-        if not isinstance(data, list):
-            raise ValueError("De API-reactie wordt niet herkend als een lijst van dictionaries.")
+    while True:
+        try:
+            response = requests.get(url, headers=headers)
+            response.raise_for_status()
 
-        # Verbinding maken met de database
-        connection = mysql.connector.connect(
-            host="localhost",
-            user="root",
-            password="",
-            database="goodgarden"
-        )
+            data = response.json()
+            load_data(data)
 
-        if connection.is_connected():
-            cursor = connection.cursor()
+            # Wacht voor een bepaalde tijd (bijvoorbeeld 60 seconden) voordat je de volgende oproep doet
+            print("Wachten voor de volgende ophaalactie...")
+            time.sleep(60)  # De tijd hier is in seconden.
 
-            # Database bijwerken met API-gegevens
-            for entry in data:
-                timestamp = entry.get("timestamp")
-                gateway_receive_time = entry.get("gateway_receive_time")
-                device = entry.get("device")
-                value = entry.get("value")
+        except requests.exceptions.RequestException as e:
+            print(f"Error fetching data: {e}")
+            # Wacht ook hier bij een fout, om niet in een snelle foutloop te komen
+            time.sleep(300)
 
-                # Gebruik van prepared statements om SQL-injectie te voorkomen
-                sql_update_query = (
-                    "UPDATE goodgarden.sensor_data "
-                    "SET timestamp=%s, gateway_receive_time=%s, device=%s "
-                    "WHERE value=%s"
-                )
-                cursor.execute(sql_update_query, (timestamp, gateway_receive_time, device, value))
-                connection.commit()
+def load_data(data):
+    mydb = database_connect()
+    if mydb.is_connected():
+        mycursor = mydb.cursor()
 
-            print("Database succesvol bijgewerkt")
+        # Hier moet je de juiste kolomnamen en dataformaten aanpassen op basis van de API-respons
+        insert_query = """
+        INSERT INTO goodgarden.sensor_data (timestamp, gateway_receive_time, device, value)
+        VALUES (%s, %s, %s, %s)
+        """
+        for record in data['results']:  # Pas dit aan op basis van de werkelijke structuur van de JSON
+            timestamp = record['timestamp']
+            gateway_receive_time = record['gateway_receive_time']
+            device = record['device']
+            value = record['value']
 
-    except Exception as e:
-        print(f"Fout bijwerken database: {e}")
+            print(f"Inserting data: timestamp={timestamp}, gateway_receive_time={gateway_receive_time}, device={device}, value={value}")  # Print de data die wordt ingevoegd
 
-    finally:
-        if connection.is_connected():
-            cursor.close()
-            connection.close()
-            print("MySQL-verbinding is gesloten")
+            # Voer de query uit
+            mycursor.execute(insert_query, (timestamp, gateway_receive_time, device, value))
 
-    # Voeg deze regel toe binnen de while-loop
-    print("Aantal gegevens uit de API:", len(data))
+        # Commit de wijzigingen
+        mydb.commit()
 
-    # Voeg een pauze toe van 10 minuten voordat de lus opnieuw wordt uitgevoerd
-    time.sleep(600)
+        # Sluit cursor en verbinding
+        mycursor.close()
+        mydb.close()
+
+        print("Data ingevoegd in de database.")
+
+if __name__ == "__main__":
+    fetch_data()