mark/synology_energy_scripts
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update gas API url

Browse Source
This commit is contained in:
mark kors
2026-03-30 20:37:06 +02:00
parent 307f995992
commit 99aeb04168
1 changed files with 80 additions and 83 deletions
Download Patch File Download Diff File Expand all files Collapse all files

61
gas.py
View File

@@ -6,17 +6,19 @@ def insert_gas_price_data():
connection = None connection = None
try: try:
url = "https://enever.nl/api/gasprijs_vandaag.php?token=5a7d9b371fe147cfc8100bcf6d9ebd55" # 1. Gasdata ophalen
url = "https://enever.nl/apiv3/gasprijs_vandaag.php?token=5a7d9b371fe147cfc8100bcf6d9ebd55"
response = requests.get(url) response = requests.get(url)
if response.status_code != 200: if response.status_code != 200:
raise Exception('Fout bij het ophalen van de gasdata.') raise Exception(f'Fout bij het ophalen van de gasdata. Status: {response.status_code}')
data = response.json() data = response.json()
if data is None or 'data' not in data: if not data or 'data' not in data:
raise Exception('Fout bij het decoderen van de JSON-data.') raise Exception('Fout bij het decoderen van de JSON-data of lege respons.')
# 2. Database verbinding
connection = mysql.connector.connect( connection = mysql.connector.connect(
host='127.0.0.1', host='127.0.0.1',
database='alfen', database='alfen',
@@ -28,47 +30,41 @@ def insert_gas_price_data():
if connection.is_connected(): if connection.is_connected():
cursor = connection.cursor() cursor = connection.cursor()
# Gebruik VALUES(price) in de update voor een schonere query
query = """ query = """
INSERT INTO gas_price_data (datetime, provider_code, price) INSERT INTO gas_price_data (datetime, provider_code, price)
VALUES (%s, %s, %s) VALUES (%s, %s, %s)
ON DUPLICATE KEY UPDATE price = %s ON DUPLICATE KEY UPDATE price = VALUES(price)
""" """
providers = { providers = {
'EGSI': 'prijsEGSI', 'EGSI': 'prijsEGSI', 'EOD': 'prijsEOD', 'ANWB': 'prijsANWB',
'EOD': 'prijsEOD', 'BE': 'prijsBE', 'EE': 'prijsEE', 'EN': 'prijsEN',
'ANWB': 'prijsANWB', 'EVO': 'prijsEVO', 'EZ': 'prijsEZ', 'FR': 'prijsFR',
'BE': 'prijsBE', 'GSL': 'prijsGSL', 'MDE': 'prijsMDE', 'NE': 'prijsNE',
'EE': 'prijsEE', 'PE': 'prijsPE', 'QU': 'prijsQU', 'SS': 'prijsSS',
'EN': 'prijsEN', 'TI': 'prijsTI', 'VDB': 'prijsVDB', 'VON': 'prijsVON',
'EVO': 'prijsEVO', 'VF': 'prijsVF', 'WE': 'prijsWE', 'ZP': 'prijsZP'
'EZ': 'prijsEZ',
'FR': 'prijsFR',
'GSL': 'prijsGSL',
'MDE': 'prijsMDE',
'NE': 'prijsNE',
'PE': 'prijsPE',
'QU': 'prijsQU',
'SS': 'prijsSS',
'TI': 'prijsTI',
'VDB': 'prijsVDB',
'VON': 'prijsVON',
'VF': 'prijsVF',
'WE': 'prijsWE',
'ZP': 'prijsZP'
} }
count = 0
for entry in data['data']: for entry in data['data']:
datetime = entry['datum'] # FIX: Schoon de datum string op voor MySQL
raw_dt = entry['datum']
clean_dt = raw_dt.replace('T', ' ').split('+')[0]
for code, price_field in providers.items(): for code, price_field in providers.items():
if price_field in entry: if price_field in entry and entry[price_field] is not None:
price = entry[price_field] price = entry[price_field]
try: try:
cursor.execute(query, (datetime, code, price, price)) cursor.execute(query, (clean_dt, code, price))
connection.commit() count += 1
except Error as e: except Error as e:
print(f"Fout bij invoeren van gasdata voor provider {code}: {e}") print(f"Fout bij klaarzetten gasdata voor {code} op {clean_dt}: {e}")
continue
# 3. Commit alle wijzigingen in een keer
connection.commit()
print(f"Succesvol {count} gasprijs-records verwerkt.")
except Error as e: except Error as e:
print(f"Fout bij databaseverbinding: {e}") print(f"Fout bij databaseverbinding: {e}")
@@ -78,6 +74,7 @@ def insert_gas_price_data():
if connection is not None and connection.is_connected(): if connection is not None and connection.is_connected():
cursor.close() cursor.close()
connection.close() connection.close()
print("Databaseverbinding gesloten.")
if __name__ == "__main__": if __name__ == "__main__":
insert_gas_price_data() insert_gas_price_data()