4

我在一个项目中使用 django ORM(在 django 之外)。我的工作流程是

  1. 通过 django ORM 选择对象和
  2. 然后使用 asyncio lib 将其发送到消息队列

问题是你不能在异步环境中调用阻塞函数,你不能在阻塞环境中使用 async/await。

我想出了2个解决方案:

  1. 整个程序应该是异步的。并loop.run_in_executor在需要时用于调用阻塞函数。

  2. 整个程序应该是同步的。并使用asyncio.run()(Python 3.7)调用所需的异步函数。

我无法决定哪种方法更好。

我知道以前有人问过类似的问题。我的问题是尝试结合阻塞和非阻塞代码时是否有一般规则?

4

1 回答 1

4

鉴于这两者之间的选择,我肯定会推荐方法#1。

#2 的缺点是通过将 asyncio 调用拆分为单独的小事件循环运行,您会错过很多 asyncio 功能。例如,您不能创建一个执行跨越多次调用的“后台”任务asyncio.run(),而这种事情对于日志记录、监控或超时非常有用。(使用asyncio.run也可能是一个性能问题,因为它会在每次调用时创建一个全新的事件循环,但这可以通过切换到来解决run_until_complete。)

但还有第三种选择:

恕我直言,这种方法结合了问题中两个选项的最佳特征。它让阻塞代码真正阻塞,仍然被允许等待事情发生,产生线程等,而不强制使用async defrun_in_executor全面使用。同时,可以使用 asyncio 最佳实践编写 asyncio 部分,并使用长时间运行的事件循环为整个程序提供服务。您只需要小心与应用程序其余部分的事件循环的所有接口甚至调用像.loop.stoploop.call_soon_threadsafeasyncio.run_coroutine_threadsafe

于 2018-05-25T05:37:27.517 回答