zenon/federated-storage
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Use delete + create instead of copy

Browse Source
This commit is contained in:
Tobias Eidelpes 2021-01-09 17:29:27 +01:00
parent 9744bdcf3b
commit 89ee1fa408
1 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
middleware/app_be/services/minioservice.py
View File

@ -45,7 +45,7 @@ class MinioService(StorageServiceInterface):
return True return True
@staticmethod @staticmethod
def move_file(identifier_from: str, identifier_to: str) -> bool: def move_file(identifier_from: str, identifier_to: str, file: bytes) -> bool:
"""Move/Rename a file on the S3 storage. """Move/Rename a file on the S3 storage.
Consists of a PUT method (copying the object) and a delete method. Consists of a PUT method (copying the object) and a delete method.
@ -56,15 +56,17 @@ class MinioService(StorageServiceInterface):
print("MinioService: Trying to move/rename file from {} to {}".format(identifier_from, identifier_to)) print("MinioService: Trying to move/rename file from {} to {}".format(identifier_from, identifier_to))
filename_from = identifier_from + '.jpg' filename_from = identifier_from + '.jpg'
filename_to = identifier_to + '.jpg' filename_to = identifier_to
url = settings.AWS_HOST + filename_to if not MinioService.delete_file(filename_from):
headers = {'x-amz-copy-source': filename_from} print("MinioService: Updating (delete) file {} failed".format(filename_from))
r = requests.put(url, headers=headers) return False
if r.status_code == 200:
print("Successfully moved/renamed the file {}!".format(filename_from)) if not MinioService.create_file(filename_to, file):
else: print("MinioService: Updating (create) file {} failed".format(filename_to))
print("Something went wrong while moving/renaming the file {}".format(filename_from)) return False
return True
@staticmethod @staticmethod
def read_file(filename: str) -> bytes: def read_file(filename: str) -> bytes: