67 lines
2.1 KiB
Python
67 lines
2.1 KiB
Python
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', [])
|
|
|
|
print("API-reactie:")
|
|
print(data)
|
|
|
|
if not isinstance(data, list):
|
|
raise ValueError("De API-reactie wordt niet herkend als een lijst van dictionaries.")
|
|
|
|
# Verbinding maken met de database
|
|
connection = mysql.connector.connect(
|
|
host="localhost",
|
|
user="root",
|
|
password="",
|
|
database="goodgarden"
|
|
)
|
|
|
|
if connection.is_connected():
|
|
cursor = connection.cursor()
|
|
|
|
# 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")
|
|
|
|
# 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()
|
|
|
|
print("Database succesvol bijgewerkt")
|
|
|
|
except Exception as e:
|
|
print(f"Fout bijwerken database: {e}")
|
|
|
|
finally:
|
|
if connection.is_connected():
|
|
cursor.close()
|
|
connection.close()
|
|
print("MySQL-verbinding is gesloten")
|
|
|
|
# Voeg deze regel toe binnen de while-loop
|
|
print("Aantal gegevens uit de API:", len(data))
|
|
|
|
# Voeg een pauze toe van 10 minuten voordat de lus opnieuw wordt uitgevoerd
|
|
time.sleep(600)
|