Attachment (S3) #19
Open
Attachment (S3) #19
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
|
Структура базы данных: class Attachment(Base):
__tablename__ = 'attachment'
id = Column(Integer, primary_key=True, autoincrement=True)
uuid = Column(String(100), nullable=False) # UUID вложения
file_path = Column(String(250), nullable=False) # Путь к файлу (это не URL)
attachment_type = Column(String(100), nullable=False) # Тип вложения: видео, фото, файл
file_extension = Column(String(100), nullable=False) # Расширение файла |
reques6e
commented
Feb 6, 2025
| @@ -9,3 +9,4 @@ aiohttp==3.11.11 | |||
| packaging==24.2 | |||
| aioboto3==13.4.0 | |||
| asyncmy==0.2.10 | |||
| boto3==1.35.63 | |||
There was a problem hiding this comment.
В новой версии есть баг
reques6e
commented
Feb 6, 2025
| 'region_name': self.region_name, | ||
| 'aws_access_key_id': self.aws_access_key_id, | ||
| 'aws_secret_access_key': self.aws_secret_access_key, | ||
| 'config': Config(signature_version='s3v4') |
There was a problem hiding this comment.
Изменил сигнатуры на s3v4
reques6e
commented
Feb 6, 2025
Comment on lines
+118
to
+120
| uuid = uuid_generate.uuid4() | ||
| file_extension = os.path.splitext(file_name)[1].lstrip('.') | ||
| new_file_name = f'{uuid}.{file_extension}' |
| file_extension = os.path.splitext(file_name)[1].lstrip('.') | ||
| new_file_name = f'{uuid}.{file_extension}' | ||
|
|
||
| file_stream = io.BytesIO(file_content) |
There was a problem hiding this comment.
Открываем файл в двоичном режиме
Comment on lines
+124
to
+125
| async with _S3Connector(S3Data) as s3: | ||
| await s3.upload_fileobj(fileobj=file_stream, key=new_file_name) |
Comment on lines
+127
to
+139
| attachment_data = Attachment( | ||
| uuid=uuid, | ||
| file_path=new_file_name, | ||
| attachment_type='file', | ||
| file_extension=file_extension | ||
| ) | ||
|
|
||
| async with async_session_maker() as session: | ||
| session.add(attachment_data) | ||
| try: | ||
| await session.commit() | ||
| except Exception as e: | ||
| await session.rollback() |
| except Exception as e: | ||
| await session.rollback() | ||
|
|
||
| return new_file_name |
Comment on lines
+98
to
+104
| S3Data = _S3Config( | ||
| bucket_name=settings.S3_BUCKET_NAME, | ||
| endpoint_url=settings.S3_ENDPOINT_URL, | ||
| region_name=settings.S3_REGION_NAME, | ||
| aws_access_key_id=settings.S3_ACCESS_KEY, | ||
| aws_secret_access_key=settings.S3_SECRET_ACCESS_KEY | ||
| ) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Нужно сделать методы Attachment для API.
Схема работы загрузки вложений:
Ответ от сервера:
{ "message": "Вложение успешно создано", "data": { "uuid": "79b1b2f0-fe4f-4976-9145-e7c6da12e731", "url": "https://s3.depotmanager.repo.reques6e.ru/", "file_type": "image", "extension": "png" } }