Django项目使用线程后无法获取Session值的问题求助

问题根源 #

1. Request对象线程不安全：Django的request对象绑定到主线程，子线程里修改的request.session只是内存副本。主线程处理完请求后，只会同步自身持有的session状态到存储（数据库/缓存），子线程的修改不会被持久化。
2. 执行时序不匹配：子线程延迟10秒执行，但主线程会立刻完成results视图处理并跳转到process视图。此时process读取的是存储中的原始session数据，子线程的修改要么还未执行，要么执行后未同步到存储，自然拿不到目标值。

解决方案 #

方案1：直接操作Session存储后端 #

绕过request对象，通过session_key直接操作Django的session存储后端，让子线程的修改直接写入持久化存储。

修改后的代码示例：

import time
import threading
from django.contrib.sessions.backends.db import SessionStore
from django.shortcuts import redirect
from django.contrib import messages

def results(request):
    user_id = request.session['user_id']

    def thread_check(session_key, user_id):
        time.sleep(10)
        hash_id, id_exists = compliance(user_id)
        # 通过session_key获取session存储实例
        session = SessionStore(session_key=session_key)
        session['hash_id'] = hash_id
        session['id_exists'] = id_exists
        # 调用save()将修改写入存储
        session.save()
        print(hash_id, "abcdefg")

    # 传入session_key而非request对象
    threads = threading.Thread(target=thread_check, args=(request.session.session_key, user_id))
    threads.start()

    request.session['check_status'] = False
    id_exists = request.session.get('id_exists')
    if id_exists:
        messages.success(request, "This File has already been analyzed")

    return redirect(process)

def process(request, stat=None):
    # 读取存储中已被修改的session数据
    hash_id = request.session.get('hash_id')
    print(hash_id, "hash id")
    check = request.session.pop('check_status', True)
    if hash_id and check:
        stat = status_mod.objects.filter(hash_id=hash_id).order_by('-id').first()
        if stat:
            stat = stat.stat_id
        print(stat, "status id ")
    
    return render(request, 'enroll/status.html', {'status': stat})

方案2：使用异步任务队列（推荐） #

手动创建线程属于Django非规范用法，易引发线程安全、资源泄漏问题。更可靠的方式是用Celery这类异步任务框架处理延迟任务：

1. 完成Celery与Django的集成配置
2. 将compliance相关逻辑封装为Celery异步任务
3. 在results视图中调用任务并设置延迟执行

这种方式符合Django设计理念，能彻底规避线程安全风险。

注意事项 #

• 使用方案1时，要确保session存储后端（如数据库）能处理并发写入，避免多线程修改同一session导致数据冲突。
• 子线程内不要调用Django视图相关逻辑，避免触发未预期的请求生命周期问题。

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