python - 异步与 Django

Question

我正在尝试在我的 Django 后处理中使用 asyncio，例如:

query : # a query to my model
tasks =  []        
for record in query:
    tasks.append(do_something_with_google_calendar(record))

loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(tasks))
loop.close()

但我只是在执行时出错:

loop = asyncio.get_event_loop()

RuntimeError: There is no current event loop in thread 'Thread-17'.

有什么想法吗？

提前致谢

Answer 1

您的原始代码不会工作，因为 get_event_loop() 方法只是 get_event_loop_policy().get_event_loop() 的快捷方式，它仅为主线程自动创建和返回事件循环。为了使其正常工作，您需要为每个当前线程上下文显式创建和设置新的事件循环:

query : # a query to my model
tasks =  []        
for record in query:
    tasks.append(do_something_with_google_calendar(record))

loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
loop.run_until_complete(asyncio.wait(tasks))
loop.close()

您可以阅读更多有关此内容的信息 here .