Djohell commited on
Commit
5899ebd
·
verified ·
1 Parent(s): 5af41c9

Upload processing.py

Browse files
Files changed (1) hide show
  1. processing.py +12 -3
processing.py CHANGED
@@ -18,13 +18,22 @@ def load_from_s3(file_name):
18
  aws_secret_access_key=os.getenv("AWS_SECRET_ACCESS_KEY"),
19
  region_name=os.getenv("AWS_REGION")
20
  )
21
- key = f"projet-economie/models/{file_name}"
22
- response = s3.get_object(Bucket=os.getenv("AWS_BUCKET_NAME"), Key=key)
 
 
 
 
 
 
 
 
23
  return json.loads(response['Body'].read().decode('utf-8'))
24
  except Exception as e:
25
- print(f"⚠️ Erreur S3 sur {file_name}: {e}")
26
  return {}
27
 
 
28
  DEP_RISK_MAP = load_from_s3("mapping_dep_risk.json")
29
  APE_SECTION_MAP = load_from_s3("mapping_ape_section.json")
30
 
 
18
  aws_secret_access_key=os.getenv("AWS_SECRET_ACCESS_KEY"),
19
  region_name=os.getenv("AWS_REGION")
20
  )
21
+
22
+ # Le nom du bucket vient de ton secret, ou on le force ici s'il est mal configuré
23
+ bucket = os.getenv("AWS_BUCKET_NAME", "projet-economie")
24
+
25
+ # LA CLÉ RÉELLE (ne doit pas contenir le nom du bucket au début)
26
+ key = f"models/{file_name}"
27
+
28
+ print(f"🔍 Tentative S3 : Bucket={bucket} | Key={key}")
29
+
30
+ response = s3.get_object(Bucket=bucket, Key=key)
31
  return json.loads(response['Body'].read().decode('utf-8'))
32
  except Exception as e:
33
+ print(f" ÉCHEC S3 sur {file_name} : {e}")
34
  return {}
35
 
36
+ # Chargement (les variables seront enfin remplies !)
37
  DEP_RISK_MAP = load_from_s3("mapping_dep_risk.json")
38
  APE_SECTION_MAP = load_from_s3("mapping_ape_section.json")
39