Python-Asyncio TypeError:无法在'等待'表达式中使用对象DICT

2022-03-25 00:00:00 python python-asyncio

问题描述

我正在使用第三方模块从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如何工作的信息。我想这会对你有很大帮助的。

相关文章