Floke/Brancheneinstufung2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

duplicate_checker.py aktualisiert

Browse Source
This commit is contained in:
Floke
2025-08-18 13:34:29 +00:00
parent bec3cea80d
commit 7cf23759c0
1 changed files with 13 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
duplicate_checker.py
View File

@@ -426,15 +426,22 @@ def main(job_id=None):
final_df = match_df.join(result_df) final_df = match_df.join(result_df)
# Bereinige die temporären Spalten für eine saubere Ausgabe # Bereinige die temporären Spalten für eine saubere Ausgabe
cols_to_drop = ['normalized_name', 'normalized_domain', 'block_keys', 'Effektive Website', 'domain_use_flag'] # KORREKTUR: 'block_key' statt 'block_keys'
final_df = final_df.drop(columns=[col for col in cols_to_drop if col in final_df.columns]) cols_to_drop = ['normalized_name', 'normalized_domain', 'block_key', 'Effektive Website', 'domain_use_flag']
final_df = final_df.drop(columns=[col for col in cols_to_drop if col in final_df.columns], errors='ignore')
# NEU: Robuster Schreibprozess zur Vermeidung von Typ-Fehlern
# 1. Alle Spalten explizit in String konvertieren, um Inkompatibilitäten mit der API (z.B. numpy-Typen) zu vermeiden.
# 2. NaN/None-Werte mit einem leeren String füllen.
upload_df = final_df.astype(str).replace({'nan': '', 'None': ''})
# Konvertiere in Liste von Listen für den Upload # Konvertiere in Liste von Listen für den Upload
data_to_write = [final_df.columns.tolist()] + final_df.fillna('').values.tolist() data_to_write = [upload_df.columns.tolist()] + upload_df.values.tolist()
logger.info(f"Versuche, {len(data_to_write) - 1} Ergebniszeilen in das Sheet '{MATCHING_SHEET_NAME}' zu schreiben...") logger.info(f"Versuche, {len(data_to_write) - 1} Ergebniszeilen in das Sheet '{MATCHING_SHEET_NAME}' zu schreiben...")
ok = sheet_handler.clear_and_write_data(MATCHING_SHEET_NAME, data_to_write) # KORREKTUR: 'sheet' statt 'sheet_handler' verwenden
ok = sheet.clear_and_write_data(MATCHING_SHEET_NAME, data_to_write)
if ok: if ok:
logger.info("Ergebnisse erfolgreich in das Google Sheet geschrieben.") logger.info("Ergebnisse erfolgreich in das Google Sheet geschrieben.")
@@ -443,9 +450,9 @@ def main(job_id=None):
logger.error("Fehler beim Schreiben der Ergebnisse ins Google Sheet.") logger.error("Fehler beim Schreiben der Ergebnisse ins Google Sheet.")
update_status(job_id, "Fehlgeschlagen", "Fehler beim Schreiben ins Google Sheet.") update_status(job_id, "Fehlgeschlagen", "Fehler beim Schreiben ins Google Sheet.")
# Summary # Summary
serp_counts = Counter((str(x).lower() for x in write_df.get('Serp Vertrauen', []))) # KORREKTUR: 'final_df' statt 'write_df' verwenden
serp_counts = Counter((str(x).lower() for x in final_df.get('Serp Vertrauen', [])))
logger.info("===== Summary =====") logger.info("===== Summary =====")
logger.info(f"Matches total: {metrics['matches_total']} | mit Domain: {metrics['matches_domain']} | mit Ort: {metrics['matches_with_loc']} | nur Name: {metrics['matches_name_only']}") logger.info(f"Matches total: {metrics['matches_total']} | mit Domain: {metrics['matches_domain']} | mit Ort: {metrics['matches_with_loc']} | nur Name: {metrics['matches_name_only']}")
logger.info(f"Serp Vertrauen: {dict(serp_counts)}") logger.info(f"Serp Vertrauen: {dict(serp_counts)}")