This commit is contained in:
lan
2023-10-24 14:02:28 +08:00
parent 248541b2e7
commit d66442233c
96 changed files with 25 additions and 52 deletions
+1
View File
@@ -17,6 +17,7 @@ default_value = {
's3_secret_access_key': '',
's3_bucket_name': '',
's3_endpoint_url': '',
'aws_session_token': '',
'onedrive_domain': '',
'onedrive_client_id': '',
'onedrive_username': '',
+2 -1
View File
@@ -90,10 +90,11 @@ class S3FileStorage(FileStorageInterface):
self.secret_access_key = settings.s3_secret_access_key
self.bucket_name = settings.s3_bucket_name
self.endpoint_url = settings.s3_endpoint_url
self.aws_session_token = settings.aws_session_token
self.session = aioboto3.Session(aws_access_key_id=self.access_key_id, aws_secret_access_key=self.secret_access_key)
async def save_file(self, file: UploadFile, save_path: str):
async with self.session.client("s3", endpoint_url=self.endpoint_url) as s3:
async with self.session.client("s3", endpoint_url=self.endpoint_url, aws_session_token=self.aws_session_token) as s3:
await s3.put_object(Bucket=self.bucket_name, Key=save_path, Body=await file.read(), ContentType=file.content_type)
async def delete_file(self, file_code: FileCodes):