|
17 | 17 | use_fips_endpoint=True, |
18 | 18 | ) |
19 | 19 |
|
20 | | -# Global variable |
21 | | -noti_s3_resource = None |
22 | 20 |
|
23 | | -default_access_key_id = os.environ.get("AWS_ACCESS_KEY_ID") |
24 | | -default_secret_access_key = os.environ.get("AWS_SECRET_ACCESS_KEY") |
25 | | -default_region = os.environ.get("AWS_REGION") |
| 21 | +default_access_key_id = os.environ.get("CSV_AWS_ACCESS_KEY_ID") |
| 22 | +default_secret_access_key = os.environ.get("CSV_AWS_SECRET_ACCESS_KEY") |
| 23 | +default_region = os.environ.get("CSV_AWS_REGION") |
26 | 24 |
|
27 | 25 |
|
28 | 26 | def get_s3_resource(): |
29 | | - global noti_s3_resource |
30 | | - if noti_s3_resource is None: |
31 | | - session = Session( |
32 | | - aws_access_key_id=os.environ.get("AWS_ACCESS_KEY_ID"), |
33 | | - aws_secret_access_key=os.environ.get("AWS_SECRET_ACCESS_KEY"), |
34 | | - region_name=os.environ.get("AWS_REGION"), |
35 | | - ) |
36 | | - noti_s3_resource = session.resource("s3", config=AWS_CLIENT_CONFIG) |
| 27 | + session = Session( |
| 28 | + aws_access_key_id=os.environ.get("CSV_AWS_ACCESS_KEY_ID"), |
| 29 | + aws_secret_access_key=os.environ.get("CSV_AWS_SECRET_ACCESS_KEY"), |
| 30 | + region_name=os.environ.get("CSV_AWS_REGION"), |
| 31 | + ) |
| 32 | + noti_s3_resource = session.resource("s3", config=AWS_CLIENT_CONFIG) |
37 | 33 | return noti_s3_resource |
38 | 34 |
|
39 | 35 |
|
@@ -72,6 +68,7 @@ def s3upload( |
72 | 68 | current_app.logger.exception( |
73 | 69 | f"Unable to upload {key} to S3 bucket because of {e}" |
74 | 70 | ) |
| 71 | + raise e |
75 | 72 | except botocore.exceptions.ClientError as e: |
76 | 73 | current_app.logger.exception( |
77 | 74 | f"Unable to upload {key}to S3 bucket because of {e}" |
|
0 commit comments