weer update
This commit is contained in:
Binary file not shown.
|
Before Width: | Height: | Size: 80 KiB After Width: | Height: | Size: 77 KiB |
@@ -167,13 +167,17 @@ def main():
|
|||||||
|
|
||||||
# 4. Filter ALLEEN de data die we nog niet hebben
|
# 4. Filter ALLEEN de data die we nog niet hebben
|
||||||
# We filteren alle data *na* de laatste datum in de DB
|
# 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
|
# We pakken alle data *na* onze laatste meting
|
||||||
# De 'upsert' query handelt eventuele overlap af
|
# 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()
|
data_om_op_te_slaan = all_data_df[all_data_df['datum_tijd'] > last_date_in_db].copy()
|
||||||
else:
|
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
|
# 5. Sla de data op
|
||||||
if not data_om_op_te_slaan.empty:
|
if not data_om_op_te_slaan.empty:
|
||||||
sla_data_op_mysql(conn, data_om_op_te_slaan)
|
sla_data_op_mysql(conn, data_om_op_te_slaan)
|
||||||
|
|||||||
Reference in New Issue
Block a user