in utils.py [0:0]
def get_object_from_s3(s3_path: str = None) -> dict:
s3 = boto3.client('s3')
try:
bucket_path = s3_path.split('/')
bucket_name = bucket_path[2]
key = bucket_path[(len(bucket_path) - 1)]
response = s3.get_object(
Bucket=bucket_name,
Key=key
)
file_contents = response['Body'].read().decode()
return file_contents
except botocore.exceptions.ClientError as error:
raise error