Django异步视图中任务未执行完成问题求助

问题原因 #

Daphne与Uvicorn的事件循环管理逻辑存在差异：当异步视图返回HTTP响应后，Daphne会清理当前请求关联的任务上下文，导致通过loop.create_task创建的后台任务在执行到await asyncio.sleep(2)时被终止；而Uvicorn会保留事件循环并继续处理未完成的后台任务，因此能正常执行完整个任务。

解决方案 #

1. 优化任务创建方式（轻量场景临时方案） #

在异步函数中，直接使用asyncio.create_task替代手动获取事件循环创建任务，它会自动绑定到当前事件循环，一定程度上适配Daphne的上下文管理：

import asyncio
from django.http import HttpResponse

async def task_async():
    print('task begin')
    await asyncio.sleep(2)
    print('task run success')

async def view_async(request):
    print('async begin')
    # 直接用asyncio.create_task创建后台任务
    asyncio.create_task(task_async())
    print('return')
    return HttpResponse("Non-blocking HTTP request")

注意：该方案仍依赖ASGI服务器的事件循环，服务器重启或请求上下文异常清理时，任务仍可能中断，仅适合无可靠性要求的轻量场景。

2. 使用专用异步任务队列（生产环境推荐） #

依赖服务器事件循环的后台任务不可靠，生产环境建议使用专门的任务队列，确保任务独立于请求上下文运行，即使服务器重启也能继续执行：

• Celery：成熟的异步任务调度框架，兼容Django，需配置Redis/RabbitMQ等消息中间件
• Django Q：轻量级Django专属任务队列，配置简单，支持异步任务执行

以Django Q为例，配置完成后可改写代码如下：

# 需先安装django-q并完成配置
from django_q.tasks import async_task

async def task_async():
    print('task begin')
    await asyncio.sleep(2)
    print('task run success')

async def view_async(request):
    print('async begin')
    # 将任务提交到独立队列
    async_task(task_async)
    print('return')
    return HttpResponse("Non-blocking HTTP request")

3. 基于Django Channels的后台任务（若使用Channels） #

如果项目已集成Django Channels，可利用其通道层实现后台任务，让任务在独立上下文运行：

from channels.layers import get_channel_layer

async def task_async():
    print('task begin')
    await asyncio.sleep(2)
    print('task run success')

async def view_async(request):
    print('async begin')
    channel_layer = get_channel_layer()
    # 发送任务到后台通道
    await channel_layer.send(
        "background_tasks",
        {"type": "run_task"},
    )
    print('return')
    return HttpResponse("Non-blocking HTTP request")

同时需定义对应的消费者处理run_task类型的消息，执行task_async函数。

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