icurfer
1d38fe26bd
All checks were successful
Build And Test / build-and-push (push) Successful in 4m25s
77 lines
2.3 KiB
Python
77 lines
2.3 KiB
Python
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 = 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):
|
|
"""
|
|
이미지 업로드 및 URL 반환
|
|
"""
|
|
if request.method == 'POST' and 'image' in request.FILES:
|
|
image = request.FILES['image']
|
|
unique_filename = f"uploads/{uuid.uuid4()}_{image.name}"
|
|
|
|
try:
|
|
# MinIO에 파일 업로드
|
|
client.put_object(
|
|
bucket_name=BUCKET_NAME,
|
|
object_name=unique_filename,
|
|
data=image,
|
|
length=image.size,
|
|
content_type=image.content_type,
|
|
)
|
|
|
|
# 전체 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)
|