Django中Asyncio代码无法执行，报错「Thread-3无当前事件循环」求助

这个报错的原因很清晰：Django的同步视图运行在普通线程里，而asyncio.get_event_loop()会尝试获取当前线程已初始化的事件循环，但你的这个线程（Thread-3）并没有创建过事件循环，所以直接抛出了错误。下面给你两种可行的解决方案：

方案一：手动创建并绑定事件循环 #

直接修改你的视图代码，创建新的事件循环并绑定到当前线程，就能正常运行异步任务了：

from django.http import HttpResponse
import asyncio

def comments(request):
    if request.method == 'POST':
        async def main():
            q = Query('Donald Trump', limit=20)
            async for tw in q.get_comments():
                print(tw)
        
        # 创建新的事件循环并绑定到当前线程
        loop = asyncio.new_event_loop()
        asyncio.set_event_loop(loop)
        try:
            loop.run_until_complete(main())
        finally:
            # 用完后关闭循环，避免资源泄漏
            loop.close()
    # 返回合适的响应，这里用简单文本示例
    return HttpResponse("评论爬取任务已执行")

方案二：使用Django异步视图（推荐） #

如果你用的是Django 3.1及以上版本，官方已经原生支持异步视图，这样你不需要手动管理事件循环，代码会更简洁规范：

from django.http import HttpResponse
import asyncio

async def comments(request):
    if request.method == 'POST':
        async def main():
            q = Query('Donald Trump', limit=20)
            async for tw in q.get_comments():
                print(tw)
        
        await main()
    return HttpResponse("评论爬取任务已执行")

额外提醒 #

如果你的爬取操作耗时较长，不建议直接在视图里执行，避免阻塞整个请求处理流程。可以考虑把爬取任务放到Celery这类异步任务队列中，或者结合Django的async_to_sync工具来处理（本质和方案一逻辑类似）。

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