Django异步支持方式及后台线程MySQL连接丢失问题咨询

1. Django 3.2.15 如何支持异步操作 #

Django 3.2作为LTS版本，对异步的支持处于过渡阶段，主要包含以下几种实现方式：

• 异步视图：支持定义async def格式的视图，但需通过ASGI服务器（如Daphne、Uvicorn）部署。若仍使用WSGI服务器（如uWSGI），Django会自动将异步视图包装到线程池中执行，无法完全发挥异步性能。示例：

  from django.http import HttpResponse
  
  async def async_view(request):
      # 执行异步IO逻辑
      return HttpResponse("Async response")
  

• 同步代码转异步：通过django.utils.asyncio.sync_to_async工具，将同步代码（如ORM操作）包装为异步可调用对象，用于异步视图或异步任务中：

  from django.utils.asyncio import sync_to_async
  from myapp.models import Task
  
  async def get_task_count():
      return await sync_to_async(Task.objects.count)()
  

• 后台异步任务：若需实现"请求立即返回、后台执行任务"的逻辑，除手动创建线程外，更推荐使用Celery这类成熟任务队列，结合Redis/RabbitMQ作为消息中间件，避免手动线程管理带来的连接泄漏、异常遗漏等问题。

2. 解决后台线程MySQL连接丢失问题 #

出现(2006, 'MySQL server has gone away')的核心原因是：后台线程复用了Web请求主线程的数据库连接，而主线程在请求结束后会自动关闭/回收该连接，导致后台线程执行ORM操作时连接已失效。以下是可行的解决方法：

方法1：手动管理后台线程的数据库连接 #

在后台任务函数开头，主动关闭继承自主线程的旧连接，重新建立当前线程专属的连接，操作完成后手动关闭：

from django.db import connection
from myapp.models import Task

class Task(models.Model):
    create_username = models.CharField(max_length=50, default='system')
    update_username = models.CharField(max_length=50, default='system')

    @classmethod
    def function(cls, params):
        # 关闭当前线程继承的旧连接（主线程已回收）
        connection.close()
        # 建立当前线程专属的数据库连接
        connection.connect()
        
        try:
            # 执行ORM逻辑
            user = params['user']
            cls.objects.create(create_username=user.username, ...)
            # 其他数据库操作...
        finally:
            # 手动关闭连接，避免连接泄漏
            connection.close()

方法2：使用Django内置工具清理旧连接 #

调用django.db.close_old_connections()函数，自动关闭所有超时或失效的连接，确保后续操作使用全新连接：

from django.db import close_old_connections
from myapp.models import Task

class Task(models.Model):
    # ...字段定义...

    @classmethod
    def function(cls, params):
        # 清理所有旧的、失效的连接
        close_old_connections()
        
        # 直接执行ORM操作，Django会自动建立新连接
        user = params['user']
        cls.objects.create(create_username=user.username, ...)

方法3：改用任务队列（推荐） #

手动管理线程和数据库连接易出现连接泄漏、异常未捕获等问题，推荐用Celery替代手动线程：

1. 配置Celery与Django集成，使用独立Worker进程执行后台任务
2. 任务函数直接编写ORM逻辑，Celery Worker会自动管理数据库连接，避免与Web请求线程的连接冲突：

# tasks.py
from celery import shared_task
from myapp.models import Task

@shared_task
def task_function(params):
    user = params['user']
    Task.objects.create(create_username=user.username, ...)

# views.py
@classmethod
def _op_function_view(cls, request):
    task_params = get_request_value(request)
    task_params['user'] = request.user
    # 异步提交任务到Celery
    task_function.delay(task_params)
    return "Task run success"

注：若坚持使用手动线程，需控制线程数量，避免数据库连接池耗尽，同时确保线程生命周期内连接始终有效。

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