diff --git a/prijs_voorspelling_windows.png b/prijs_voorspelling_windows.png index 29cd6ac..7de974b 100644 Binary files a/prijs_voorspelling_windows.png and b/prijs_voorspelling_windows.png differ diff --git a/update_weather.py b/update_weather.py index a0e2ee6..24532ea 100644 --- a/update_weather.py +++ b/update_weather.py @@ -167,13 +167,17 @@ def main(): # 4. Filter ALLEEN de data die we nog niet hebben # We filteren alle data *na* de laatste datum in de DB - if last_date_in_db is not None: + """ if last_date_in_db is not None: # We pakken alle data *na* onze laatste meting # De 'upsert' query handelt eventuele overlap af data_om_op_te_slaan = all_data_df[all_data_df['datum_tijd'] > last_date_in_db].copy() else: - data_om_op_te_slaan = all_data_df.copy() # Alles is nieuw + data_om_op_te_slaan = all_data_df.copy() # Alles is nieuw """ + # 4. Stuur *alle* opgehaalde data naar MySQL. + # De 'ON DUPLICATE KEY' query regelt de updates en inserts. + data_om_op_te_slaan = all_data_df.copy() + # 5. Sla de data op if not data_om_op_te_slaan.empty: sla_data_op_mysql(conn, data_om_op_te_slaan)