Skip to content

Commit

Permalink
fix: resolve runtime error when self.folder is None (#8401)
Browse files Browse the repository at this point in the history
Co-authored-by: 陈长君 <[email protected]>
  • Loading branch information
swingchen01 and 陈长君 authored Sep 14, 2024
1 parent b613b11 commit f55e06d
Showing 1 changed file with 14 additions and 34 deletions.
48 changes: 14 additions & 34 deletions api/extensions/storage/aliyun_storage.py
Original file line number Diff line number Diff line change
Expand Up @@ -31,54 +31,34 @@ def __init__(self, app: Flask):
)

def save(self, filename, data):
if not self.folder or self.folder.endswith("/"):
filename = self.folder + filename
else:
filename = self.folder + "/" + filename
self.client.put_object(filename, data)
self.client.put_object(self.__wrapper_folder_filename(filename), data)

def load_once(self, filename: str) -> bytes:
if not self.folder or self.folder.endswith("/"):
filename = self.folder + filename
else:
filename = self.folder + "/" + filename

with closing(self.client.get_object(filename)) as obj:
with closing(self.client.get_object(self.__wrapper_folder_filename(filename))) as obj:
data = obj.read()
return data

def load_stream(self, filename: str) -> Generator:
def generate(filename: str = filename) -> Generator:
if not self.folder or self.folder.endswith("/"):
filename = self.folder + filename
else:
filename = self.folder + "/" + filename

with closing(self.client.get_object(filename)) as obj:
with closing(self.client.get_object(self.__wrapper_folder_filename(filename))) as obj:
while chunk := obj.read(4096):
yield chunk

return generate()

def download(self, filename, target_filepath):
if not self.folder or self.folder.endswith("/"):
filename = self.folder + filename
else:
filename = self.folder + "/" + filename

self.client.get_object_to_file(filename, target_filepath)
self.client.get_object_to_file(self.__wrapper_folder_filename(filename), target_filepath)

def exists(self, filename):
if not self.folder or self.folder.endswith("/"):
filename = self.folder + filename
else:
filename = self.folder + "/" + filename

return self.client.object_exists(filename)
return self.client.object_exists(self.__wrapper_folder_filename(filename))

def delete(self, filename):
if not self.folder or self.folder.endswith("/"):
filename = self.folder + filename
else:
filename = self.folder + "/" + filename
self.client.delete_object(filename)
self.client.delete_object(self.__wrapper_folder_filename(filename))

def __wrapper_folder_filename(self, filename) -> str:
if self.folder:
if self.folder.endswith("/"):
filename = self.folder + filename
else:
filename = self.folder + "/" + filename
return filename

0 comments on commit f55e06d

Please sign in to comment.