nouffer/rogaining_srv
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fix PDF issue

Browse Source
This commit is contained in:
hayano
2024-11-09 09:50:58 +00:00
parent 27aed10a4a
commit 2ca77b604b
6 changed files with 300 additions and 101 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
rog/utils.py
View File

@ -1,5 +1,5 @@
import os
from aiohttp import ClientError
from botocore.exceptions import ClientError
from django.template.loader import render_to_string
from django.conf import settings
import logging
@ -193,12 +193,12 @@ class S3Bucket:
s3_key = os.path.basename(file_path)
# S3クライアントが指定されていない場合は新規作成
if s3_client is None:
s3_client = self.connect()
if self.s3_client is None:
self.s3_client = self.connect()
# ファイルのアップロード
logger.info(f"アップロード開始: {file_path} → s3://{self.bucket_name}/{s3_key}")
s3_client.upload_file(file_path, self.bucket_name, s3_key)
self.s3_client.upload_file(file_path, self.bucket_name, s3_key)
logger.info("アップロード完了")
return True
@ -313,11 +313,11 @@ class S3Bucket:
try:
# S3クライアントが指定されていない場合は新規作成
if s3_client is None:
s3_client = self.connect()
if self.s3_client is None:
self.s3_client = self.connect()
# プレフィックスに一致するオブジェクトをリスト
paginator = s3_client.get_paginator('list_objects_v2')
paginator = self.s3_client.get_paginator('list_objects_v2')
pages = paginator.paginate(Bucket=self.bucket_name, Prefix=prefix)
for page in pages:
@ -361,12 +361,12 @@ class S3Bucket:
try:
# S3クライアントが指定されていない場合は新規作成
if s3_client is None:
s3_client = self.connect()
if self.s3_client is None:
self.s3_client = self.connect()
# オブジェクトの削除
logger.info(f"削除開始: s3://{self.bucket_name}/{s3_key}")
s3_client.delete_object(Bucket=self.bucket_name, Key=s3_key)
self.s3_client.delete_object(Bucket=self.bucket_name, Key=s3_key)
logger.info("削除完了")
return True