Django异步count操作长时间无响应：排查方法与原因分析

可能的原因 #

• 事件循环冲突：你在同步视图里用asyncio.run()创建了新的事件循环，但Django的异步ORM方法（如acount()）依赖当前上下文的数据库连接，新循环没绑定正确的数据库上下文，导致IO操作挂起。
• 同步/异步上下文不兼容：Django的异步ORM操作需要在异步上下文（异步视图、异步任务）中执行，同步视图直接调用asyncio.run()会破坏数据库连接的生命周期管理，请求因此卡住。

调试步骤 #

• 检查数据库连接状态：在before getting count后加日志，打印当前数据库连接情况：

  from django.db import connections
  print(f"默认DB连接存在: {'default' in connections}")
  print(f"DB连接可用: {connections['default'].usable()}")
  

• 捕获异步异常：给asyncio.run()加try-except，打印完整异常栈：

  try:
      t = asyncio.run(self.aget_count_async(request, *args, **kwargs))
  except Exception as e:
      import traceback
      traceback.print_exc()
  

• 替换同步方法测试：暂时把await User.objects.filter(id="1").acount()换成同步的User.objects.filter(id="1").count()，如果能正常走到after getting count，说明问题就是异步ORM的上下文兼容问题。

修复方案 #

方案1：改用异步视图（推荐） #

DRF支持异步视图集，直接把视图方法改成async def，不用手动管理事件循环：

class SomeViewSet(ListUpdateViewSet):
    @action(
        methods=["GET"],
        url_path=r"count-async",
        detail=False
    )
    async def get_count_async(self, request, *args, **kwargs):
        print('starting')
        my_count = await User.objects.filter(id="1").acount()
        print('ending')
        return Response(data={"count": my_count})

方案2：同步视图中用线程池包装异步任务 #

如果必须保留同步视图，用线程池隔离事件循环，避免和Django的上下文冲突：

import asyncio
from concurrent.futures import ThreadPoolExecutor

class SomeViewSet(ListUpdateViewSet):
    @action(
        methods=["GET"],
        url_path=r"count-async",
        detail=False
    )
    def get_count_async(self, request, *args, **kwargs):
        print('starting')

        def run_async():
            loop = asyncio.new_event_loop()
            asyncio.set_event_loop(loop)
            return loop.run_until_complete(self.aget_count_async(request, *args, **kwargs))
        
        with ThreadPoolExecutor() as executor:
            count_result = executor.submit(run_async).result()
        
        print('ending')
        return Response(data={"count": count_result})

    async def aget_count_async(self, request, *args, **kwargs):
        print('before getting count')
        my_count = await User.objects.filter(id="1").acount()
        print('after getting count')
        return my_count

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