minio 테스트 인증정보 삭제, 변수 처리 완료
All checks were successful
Build And Test / build-and-push (push) Successful in 4m25s
All checks were successful
Build And Test / build-and-push (push) Successful in 4m25s
This commit is contained in:
@ -5,4 +5,5 @@ app_name = 'obs_minio'
|
||||
|
||||
urlpatterns = [
|
||||
path('upload/', views.upload_image, name='upload_image'),
|
||||
path('get_presigned_url/', views.get_presigned_url, name='get_presigned_url'),
|
||||
]
|
||||
|
@ -1,32 +1,37 @@
|
||||
import uuid
|
||||
from django.conf import settings
|
||||
from django.http import JsonResponse
|
||||
from django.views.decorators.csrf import csrf_exempt
|
||||
from minio import Minio
|
||||
from minio.error import S3Error
|
||||
import json
|
||||
import uuid
|
||||
import urllib3
|
||||
|
||||
# MinIO 설정
|
||||
MINIO_ENDPOINT = 'minio.icurfer.com:9000'
|
||||
MINIO_ACCESS_KEY = 'h5gOXcQieSE0kReVlpDa'
|
||||
MINIO_SECRET_KEY = '2S5vtc7DtrnUjqsAO6CF3kPVEqDtqmHgnt3OPIPY'
|
||||
BUCKET_NAME = 'butler-ddochi-image'
|
||||
MINIO_ENDPOINT = settings.MINIO_ENDPOINT_URL
|
||||
MINIO_ACCESS_KEY = settings.MINIO_ACCESS_KEY
|
||||
MINIO_SECRET_KEY = settings.MINIO_SECRET_KEY
|
||||
BUCKET_NAME = settings.MINIO_DEFAULT_BUCKET
|
||||
|
||||
# MinIO 클라이언트 생성
|
||||
client = Minio(
|
||||
MINIO_ENDPOINT,
|
||||
access_key=MINIO_ACCESS_KEY,
|
||||
secret_key=MINIO_SECRET_KEY,
|
||||
secure=True,
|
||||
http_client=urllib3.PoolManager(cert_reqs='CERT_NONE') # SSL 검증 비활성화
|
||||
)
|
||||
|
||||
|
||||
@csrf_exempt
|
||||
def upload_image(request):
|
||||
print("이미지업로드 동작시작")
|
||||
"""
|
||||
이미지 업로드 및 URL 반환
|
||||
"""
|
||||
if request.method == 'POST' and 'image' in request.FILES:
|
||||
image = request.FILES['image']
|
||||
unique_filename = f"uploads/{uuid.uuid4()}_{image.name}"
|
||||
|
||||
# MinIO 클라이언트 생성
|
||||
client = Minio(
|
||||
MINIO_ENDPOINT,
|
||||
access_key=MINIO_ACCESS_KEY,
|
||||
secret_key=MINIO_SECRET_KEY,
|
||||
secure=True,
|
||||
http_client=urllib3.PoolManager(cert_reqs='CERT_NONE') # SSL 검증 비활성화
|
||||
)
|
||||
|
||||
try:
|
||||
# MinIO에 파일 업로드
|
||||
client.put_object(
|
||||
@ -34,14 +39,38 @@ def upload_image(request):
|
||||
object_name=unique_filename,
|
||||
data=image,
|
||||
length=image.size,
|
||||
content_type=image.content_type
|
||||
content_type=image.content_type,
|
||||
)
|
||||
|
||||
# Presigned URL 생성
|
||||
presigned_url = client.presigned_get_object(BUCKET_NAME, unique_filename)
|
||||
return JsonResponse({"url": presigned_url}, status=201)
|
||||
# 전체 URL 생성
|
||||
full_url = f"https://{MINIO_ENDPOINT}/{BUCKET_NAME}/{unique_filename}"
|
||||
return JsonResponse({"url": full_url}, status=201)
|
||||
|
||||
except S3Error as e:
|
||||
return JsonResponse({"error": str(e)}, status=500)
|
||||
|
||||
return JsonResponse({"error": "Invalid request"}, status=400)
|
||||
|
||||
|
||||
@csrf_exempt
|
||||
def get_presigned_url(request):
|
||||
"""
|
||||
Presigned URL 생성 및 반환
|
||||
"""
|
||||
if request.method == 'POST':
|
||||
try:
|
||||
data = json.loads(request.body)
|
||||
object_name = data.get('object_name')
|
||||
|
||||
if not object_name:
|
||||
return JsonResponse({"error": "Missing object_name"}, status=400)
|
||||
|
||||
# Presigned URL 생성
|
||||
presigned_url = client.presigned_get_object(BUCKET_NAME, object_name)
|
||||
return JsonResponse({"presigned_url": presigned_url}, status=200)
|
||||
except S3Error as e:
|
||||
return JsonResponse({"error": str(e)}, status=500)
|
||||
except json.JSONDecodeError:
|
||||
return JsonResponse({"error": "Invalid JSON"}, status=400)
|
||||
|
||||
return JsonResponse({"error": "Invalid request method"}, status=405)
|
||||
|
Reference in New Issue
Block a user