SCHOON

mqtt/db_connect.py

@@ -1,36 +0,0 @@
-# Importeer de benodigde modules voor MySQL connectiviteit.
-import mysql.connector
-from mysql.connector import Error
-
-def database_connect():
-    """
-    Maakt verbinding met de MySQL database.
-
-    Probeert een verbinding met de MySQL-database op te zetten met behulp van
-    de mysql.connector.connect methode, gebruikmakend van de database
-    credentials. Bij succes retourneert het de verbinding; bij een mislukking
-    vangt het de fout op en print een bericht.
-
-    Returns:
-        connection (mysql.connector.connect object): Een connectie object als
-        de verbinding succesvol is. Anders None.
-    """
-    try:
-        # Probeert een verbinding op te zetten met de MySQL database.
-        connection = mysql.connector.connect(
-            host="localhost",  # Database host
-            user="root",       # Database gebruikersnaam
-            password="",       # Database wachtwoord
-            database="goodgarden"  # Database naam
-        )
-
-        # Controleert of de verbinding succesvol was.
-        if connection.is_connected():
-            return connection  # Retourneert het verbinding object.
-
-    except Error as e:
-        # Vangt en print elke fout die optreedt tijdens het verbindingsproces.
-        print(f"Connection NIET gelukt! ${e}")
-    
-    # Retourneert None als de verbinding mislukt.
-    return None

mqtt/publisher.py

@@ -7,7 +7,7 @@ import json
 from mqtt_client import create_client, start_loop  
 
 # Stel het interval in seconden in voor het periodiek ophalen en publiceren van data.
-publish_interval = 900  # MOET ~900 ZIJN voor productiegebruik. -- 15min
+publish_interval = 900  # MOET ~900 ZIJN. -- 15min
 
 # Definieer API-eindpunten en de corresponderende MQTT topics.
 api_endpoints = [
@@ -65,7 +65,7 @@ def fetch_and_publish_data():
     for endpoint in api_endpoints:
         url = endpoint["url"]
         mqtt_topic = endpoint["topic"]
-        access_token = "33bb3b42452306c58ecedc3c86cfae28ba22329c"  # Voorbeeld token.
+        access_token = "33bb3b42452306c58ecedc3c86cfae28ba22329c"
 
         try:
             headers = {"Authorization": f"Token {access_token}"}
@@ -84,4 +84,4 @@ if __name__ == "__main__":
         print(f"\033[91mWachten, wachten en nog eens wachten... {publish_interval} secondes!\033[0m\n")
         time.sleep(publish_interval)  # Wacht voor het ingestelde interval.
 
-        client.loop_stop()
+        client.loop_stop()