Kubernetes容器中使用threading.local()获取当前用户返回None问题排查

开发者阿泽

2026-8-21

问题原因及解决办法

以下是导致Kubernetes容器中get_current_user()返回None的常见原因及对应解决方案：

线程/协程上下文隔离机制不匹配
本地开发通常用WSGI服务器（如Django自带的runserver），依赖threading.local()实现线程级隔离；但K8s部署时如果使用ASGI服务器（如Uvicorn、Daphne），协程会在同一线程内切换，threading.local()无法实现协程级隔离，导致上下文丢失。
解决：改用Python标准库的contextvars替代threading.local()，它支持协程安全的上下文存储。修改核心代码示例：
```
import contextvars

USER_ATTR_NAME = getattr(settings, "LOCAL_USER_ATTR_NAME", "_current_user")
_user_context = contextvars.ContextVar(USER_ATTR_NAME, default=None)

def _do_set_current_user(user_fun):
    _user_context.set(user_fun)

def get_current_user():
    current_user = _user_context.get()
    if callable(current_user):
        return current_user()
    return current_user
```
中间件顺序配置错误
如果SelfServeCurrentUserMiddleware在Django认证中间件（django.contrib.auth.middleware.AuthenticationMiddleware）之前执行，此时request.user还未被初始化，自然返回None。本地开发可能配置正确，但K8s部署的settings.MIDDLEWARE顺序有误。
解决：在settings.MIDDLEWARE中将SelfServeCurrentUserMiddleware放在AuthenticationMiddleware之后，确保request.user已被正确设置。
异步任务/视图上下文未传递
如果在异步任务（如Celery）或异步视图中调用get_current_user()，中间件仅在请求主线程/协程中设置了上下文，异步任务的独立上下文无法继承threading.local()的值。
解决：在启动异步任务时显式传递用户信息，或使用支持上下文传递的任务框架（如Django 3.1+的异步视图配合contextvars）。
环境变量/配置项不一致
本地settings未设置LOCAL_USER_ATTR_NAME，使用默认的_current_user；但K8s部署的settings中配置了该变量，导致USER_ATTR_NAME与中间件存储用户信息的键不匹配，getattr无法获取到值。
解决：统一本地与K8s环境的LOCAL_USER_ATTR_NAME配置，或直接固定使用默认值避免差异。

线程复用导致上下文异常
K8s中使用的服务器（如Gunicorn）通常启用线程池，线程被复用时，threading.local()中的旧值未被清理，或新请求的中间件未及时覆盖旧值，导致获取到错误的上下文。
解决：在中间件的响应阶段清理上下文，确保线程复用前状态重置：

class SelfServeCurrentUserMiddleware(object):
    def __init__(self, get_response):
        self.get_response = get_response

    def __call__(self, request):
        _do_set_current_user(lambda self: getattr(request, "user", None))
        try:
            response = self.get_response(request)
        finally:
            # 清理上下文
            setattr(_thread_locals, USER_ATTR_NAME, None)
        return response

内容的提问来源于stack exchange，提问作者jenesaisquoi