ajout des repertoires de travail

src/pages/utils/utils.py

@@ -57,6 +57,27 @@ async def async_load_file_s3_gzip(object_key: str) -> pd.DataFrame:
             "AWS credentials or bucket name not set in environment variables."
         )
 
+    session = get_session()
+    async with session.create_client(
+        "s3",
+        aws_access_key_id=AWS_ACCESS_KEY_ID,
+        aws_secret_access_key=AWS_SECRET_ACCESS_KEY,
+    ) as s3_client:
+        response = await s3_client.get_object(Bucket=AWS_S3_BUCKET, Key=object_key)
+        status = response.get("ResponseMetadata", {}).get("HTTPStatusCode")
+        if status == 200:
+            async with response["Body"] as stream:
+                content = await stream.read()
+            return pd.read_csv(io.BytesIO(content), compression="gzip")
+        raise ValueError(f"Unsuccessful S3 get_object response. Status - {status}")
+
+
+async def async_load_file_s3_zip(object_key: str) -> pd.DataFrame:
+    if not AWS_S3_BUCKET or not AWS_ACCESS_KEY_ID or not AWS_SECRET_ACCESS_KEY:
+        raise ValueError(
+            "AWS credentials or bucket name not set in environment variables."
+        )
+
     session = get_session()
     async with session.create_client(
         "s3",