如何在Django自定义S3Boto3Storage类中获取请求以动态设置S3存储桶？

要让自定义S3存储类能根据当前用户的配置切换Bucket，核心难点是存储类默认初始化时没有请求上下文（request对象）。这里有两种实用的解决方案，你可以根据场景选择：

方案一：在类视图中动态实例化存储类（推荐，无全局依赖） #

这种方法不需要修改存储类的全局逻辑，而是在处理上传的视图里，根据当前用户的信息动态创建存储实例，直接指定对应的Bucket。

第一步：修改自定义存储类，支持传入Bucket参数 #

from storages.backends.s3boto3 import S3Boto3Storage

class CustomS3Storage(S3Boto3Storage):
    def __init__(self, bucket_name=None, *args, **kwargs):
        super().__init__(*args, **kwargs)
        # 如果传入了bucket_name就用用户的，否则用默认值
        self.bucket_name = bucket_name or 'app-files'

第二步：在类视图中动态处理文件上传 #

比如在你的上传类视图里，重写form_valid方法，获取当前用户的Bucket，实例化存储类后再保存文件：

from django.views.generic.edit import CreateView
from django.contrib.auth.mixins import LoginRequiredMixin
from .models import YourFileModel
from .storage import CustomS3Storage

class UserFileUploadView(LoginRequiredMixin, CreateView):
    model = YourFileModel
    fields = ['uploaded_file']

    def form_valid(self, form):
        # 获取当前用户绑定的Bucket
        user_bucket = self.request.user.profile.bucket
        # 实例化带指定Bucket的存储类
        user_storage = CustomS3Storage(bucket_name=user_bucket)
        
        # 取出表单中的上传文件
        uploaded_file = form.cleaned_data['uploaded_file']
        # 用用户专属的存储类保存文件
        saved_file_path = user_storage.save(uploaded_file.name, uploaded_file)
        
        # 将保存后的路径赋值给模型实例
        form.instance.uploaded_file.name = saved_file_path
        return super().form_valid(form)

优点：逻辑清晰，没有全局上下文依赖，不会影响其他不需要动态切换Bucket的场景；缺点：需要在每个涉及文件上传的视图中重复这段逻辑（可以封装成Mixin复用）。

方案二：用线程本地存储传递Request上下文（全局通用） #

如果希望所有使用该存储类的地方都自动根据当前用户切换Bucket，可以通过中间件把Request对象存入线程本地存储，让存储类能直接获取到请求上下文。

第一步：编写Request中间件 #

创建一个中间件，把当前请求存入线程本地变量（线程安全，Django每个请求对应一个独立线程）：

# middleware.py
import threading
from django.utils.deprecation import MiddlewareMixin

# 线程本地存储，用于临时保存当前请求
thread_local = threading.local()

class RequestContextMiddleware(MiddlewareMixin):
    def process_request(self, request):
        thread_local.request = request

    def process_response(self, request, response):
        # 请求结束后清理变量，避免内存泄漏
        if hasattr(thread_local, 'request'):
            del thread_local.request
        return response

记得把这个中间件添加到settings.py的MIDDLEWARE列表中（建议放在靠前的位置）。

第二步：修改自定义存储类获取Request #

from storages.backends.s3boto3 import S3Boto3Storage
from .middleware import thread_local

class CustomS3Storage(S3Boto3Storage):
    def __init__(self, *args, **kwargs):
        super().__init__(*args, **kwargs)
        # 从线程本地获取当前请求
        request = getattr(thread_local, 'request', None)
        
        # 仅当用户已认证且存在Bucket配置时切换
        if request and request.user.is_authenticated:
            try:
                self.bucket_name = request.user.profile.bucket
            except AttributeError:
                # 处理用户没有profile或Bucket的情况，用默认值
                self.bucket_name = 'app-files'
        else:
            # 匿名用户或无请求上下文时用默认Bucket
            self.bucket_name = 'app-files'

优点：全局生效，所有使用CustomS3Storage的FileField都会自动切换Bucket；缺点：依赖中间件和线程本地存储，后台任务（如Celery）中没有请求上下文时会使用默认Bucket，需要单独处理这类场景。

内容的提问来源于stack exchange，提问作者Frank de Wijk