From b5a6dde1a51d5253567e0a4cb10dd56e2f0d2c82 Mon Sep 17 00:00:00 2001 From: Nik Afiq Date: Mon, 13 May 2024 09:43:11 +0900 Subject: [PATCH] crm-datafech fix --- ecs/crm-datafetch/src/aws/s3.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/ecs/crm-datafetch/src/aws/s3.py b/ecs/crm-datafetch/src/aws/s3.py index 17e4a1f3..ed062fca 100644 --- a/ecs/crm-datafetch/src/aws/s3.py +++ b/ecs/crm-datafetch/src/aws/s3.py @@ -14,21 +14,21 @@ from src.system_var.environments import (CRM_BACKUP_BUCKET, CRM_CONFIG_BUCKET, class S3Resource: def __init__(self, bucket_name: str) -> None: - self.__s3_resource = boto3.resource(AWS_RESOURCE_S3) - self.__s3_bucket = self.__s3_resource.Bucket(bucket_name) + self.__s3_client = boto3.client(AWS_RESOURCE_S3) + self.__s3_bucket = bucket_name def get_object(self, object_key: str) -> str: - response = self.__s3_bucket.Object(object_key).get() + response = self.__s3_client.get_object(Bucket=self.__s3_bucket, Key=object_key) body = response[S3_RESPONSE_BODY].read() return body.decode(S3_CHAR_CODE) def put_object(self, object_key: str, local_file_path: str) -> None: - self.__s3_bucket.upload_file(Key=object_key, Filename=local_file_path) + self.__s3_client.upload_file(Filename=local_file_path, Bucket=self.__bucket_name, Key=object_key) return def copy(self, src_bucket: str, src_key: str, dest_bucket: str, dest_key: str) -> None: copy_source = {'Bucket': src_bucket, 'Key': src_key} - self.__s3_resource.meta.client.copy(copy_source, dest_bucket, dest_key) + self.__s3_client.copy_object(CopySource=copy_source, Bucket=dest_bucket, Key=dest_key) return