Lazyframe dès le départ

2025-09-19 08:26:03 +02:00
parent e8eba9ba66
commit b93b290f97
1 changed files with 2 additions and 4 deletions
@@ -110,14 +110,12 @@ def get_decp_data() -> pl.LazyFrame:
        logger.info(
            f"Lecture du fichier parquet ({os.getenv('DATA_FILE_PARQUET_PATH')})..."
        )
-        df: pl.DataFrame = pl.read_parquet(os.getenv("DATA_FILE_PARQUET_PATH"))
+        lff: pl.LazyFrame = pl.scan_parquet(os.getenv("DATA_FILE_PARQUET_PATH"))
    except ComputeError:
        # Le fichier est probablement en cours de mise à jour
        logger.info("Échec, nouvelle tentative dans 10s...")
        sleep(10)
-        df: pl.DataFrame = pl.read_parquet(os.getenv("DATA_FILE_PARQUET_PATH"))
-
-    lff: pl.LazyFrame = df.lazy()
+        lff: pl.LazyFrame = pl.scan_parquet(os.getenv("DATA_FILE_PARQUET_PATH"))

    # Remplacement des valeurs numériques par des chaînes de caractères
    # lff = numbers_to_strings(lff)