Python-Asyncio TypeError:无法在';等待';表达式中使用对象DICT
问题描述
我正在使用第三方模块从API检索数据。我只是想异步地等待模块返回数据,这有时会花费几秒钟的时间,并冻结我的应用程序。但是,当我尝试等待对模块调用时,收到了TypeError:
TypeError: object dict can't be used in 'await' expression
import thirdPartyAPIwrapper
async def getData():
retrienveData = await thirdPartyAPIWrapper.data()
return await retrieveData
def main():
loop = asncio.get_event_loop()
data = loop.run_until_complete(getData())
loop.close
return data
为什么我不能等待一个类型(‘dict’)?有什么办法可以绕过这件事吗? 如果Async/AWait with Ayncio不能与不返回协程的第三方模块一起工作,那么还有其他选择吗?
解决方案
只能等待异步(用async def
定义)函数。整个想法是,这样的函数是以特殊的方式编写的,这样就可以在不阻塞事件循环的情况下运行(await
)它们。
如果您想要从执行耗时较长的公共函数(用def
定义)获得结果,您可以选择以下选项:
- 将整个函数重写为异步
- 在另一个线程中调用此函数并异步等待结果
- 在另一个进程中调用此函数并异步等待结果
通常您希望选择第二个选项。
以下是如何操作的示例:
import asyncio
import time
from concurrent.futures import ThreadPoolExecutor
_executor = ThreadPoolExecutor(1)
def sync_blocking():
time.sleep(2)
async def hello_world():
# run blocking function in another thread,
# and wait for it's result:
await loop.run_in_executor(_executor, sync_blocking)
loop = asyncio.get_event_loop()
loop.run_until_complete(hello_world())
loop.close()
请阅读this answer有关Ayncio如何工作的信息。我想这会对你有很大帮助的。
相关文章