MinIO on Django: Quick Intro and Popular Python Bindings

INSTALLED_APPS = [
    ...
    'minio_storage',
    ...
]

# Use Minio as file storage backend

STATIC_ROOT = './static_files/'
DEFAULT_FILE_STORAGE = "minio_storage.storage.MinioMediaStorage"
MINIO_STORAGE_ENDPOINT = environ['MINIO_ADDRESS']
MINIO_STORAGE_ACCESS_KEY = environ['MINIO_ACCESS_KEY']
MINIO_STORAGE_SECRET_KEY = environ['MINIO_SECRET_KEY']
# 这个选项控制手动连接 MinIO 的时候使用的 HTTP Scheme
MINIO_STORAGE_USE_HTTPS = False
MINIO_STORAGE_MEDIA_OBJECT_METADATA = {"Cache-Control": "max-age=1000"}
MINIO_STORAGE_MEDIA_URL = environ['MINIO_ADDRESS']
MINIO_STORAGE_MEDIA_BUCKET_NAME = 'media-bucket'
# 这个选项控制 Django 如何使用存储：从 Django 中写文件时是否会自动创建对应的存储桶
MINIO_STORAGE_AUTO_CREATE_MEDIA_BUCKET = True
MINIO_STORAGE_STATIC_BUCKET_NAME = 'static-bucket'
MINIO_STORAGE_AUTO_CREATE_STATIC_BUCKET = True

from django.utils import timezone

from rest_framework.permissions import AllowAny
from rest_framework.response import Response
from rest_framework.views import APIView

from django.core.files.base import ContentFile
from django.core.files.storage import default_storage
from django.core.files.storage import Storage
from django.core.files import File

class StatusView(APIView):
# Omit unrelated codes
    def minio_connected(self):
        try:
            testfile_content = b'minio here'
            path = default_storage.save('here/alive', ContentFile(testfile_content))
            testfile_content_read = default_storage.open(path).read()
            default_storage.delete(path)
            return testfile_content == testfile_content_read
        except Exception:
            return False

import json
import datetime

from minio import Minio
from minio.error import ResponseError
from datetime import timedelta
from os import environ

from .settings import MINIO_STORAGE_MEDIA_BUCKET_NAME as DEFAULT_BUCKET
from .settings import MINIO_STORAGE_USE_HTTPS

import random

# minio client to use
# TODO: when deployed and access through remote machine,
#       minio remote address should be changed to HTTP_HOST
#       with corresponding information.
local_minio_client = Minio(
    environ['MINIO_ADDRESS'],
    access_key=environ['MINIO_ACCESS_KEY'],
    secret_key=environ['MINIO_SECRET_KEY'],
    secure=MINIO_STORAGE_USE_HTTPS,
)
# default timeout = 15 min
DEFAULT_TIMEOUT = timedelta(minutes=15)

# PREFIX DIR

PREFIX = "******"

file_token = f"{PREFIX}/{file_display_name}"

put_url = local_minio_client.presigned_url("PUT",
                                            DEFAULT_BUCKET,
                                            file_token,
                                            expires=DEFAULT_TIMEOUT)

print(put_url)

# imports and minio client are omitted

file_token = "******"
result_url = local_minio_client.presigned_url("GET",
                                            DEFAULT_BUCKET,
                                            file_token,
                                            expires=DEFAULT_FILE_URL_TIMEOUT)

print(result_url)

# imports and minio client are omitted
from minio import PostPolicy

# MAX SIZE (MB)
MAX_SIZE = 4 * 1024 * 1024

post_policy = PostPolicy()
# set bucket name location for uploads.
post_policy.set_bucket_name(DEFAULT_BUCKET)
# set key prefix for all incoming uploads.
file_token = "******"
post_policy.set_key_startswith(file_token)
# set content length for incoming uploads.
post_policy.set_content_length_range(0, MAX_SIZE)
# set expiry.
expires_date = datetime.utcnow() + DEFAULT_FILE_URL_TIMEOUT
post_policy.set_expires(expires_date)


url, signed_form_data = local_minio_client.presigned_post_policy(post_policy)

print(url)
print(signed_form_data)

# imports and minio client are omitted

# predefined anonymous read-only avatar policy
predefined_avatar_policy = {
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Principal": {"AWS": "*"},
            "Action": "s3:GetObject",
            "Resource": f"arn:aws:s3:::{DEFAULT_BUCKET}/{PREFIX}/*",
        },
    ],
}

local_minio_client.set_bucket_policy(DEFAULT_BUCKET, json.dumps(predefined_avatar_policy))