selfhostyourtech/reflector
2
0
Fork 0
mirror of https://github.com/Monadical-SAS/reflector.git synced 2026-04-25 06:35:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix transcript reprocessing

Browse Source
This commit is contained in:
Sergey Mankovsky
2025-01-21 16:52:51 +01:00
parent 97a8f806aa
commit 753a2615db
4 changed files with 36 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
server/reflector/storage/base.py
View File

@@ -52,3 +52,9 @@ class Storage:
async def _get_file_url(self, filename: str) -> str:
raise NotImplementedError
async def get_file(self, filename: str):
return await self._get_file(filename)
async def _get_file(self, filename: str):
raise NotImplementedError

9
server/reflector/storage/storage_aws.py
View File

@@ -65,5 +65,14 @@ class AwsStorage(Storage):
async with self.session.client("s3") as client:
await client.delete_object(Bucket=bucket, Key=s3filename)
async def _get_file(self, filename: str):
bucket = self.aws_bucket_name
folder = self.aws_folder
logger.info(f"Downloading {filename} from S3 {bucket}/{folder}")
s3filename = f"{folder}/{filename}" if folder else filename
async with self.session.client("s3") as client:
response = await client.get_object(Bucket=bucket, Key=s3filename)
return await response["Body"].read()
Storage.register("aws", AwsStorage)