代码之家 › 专栏 › 技术社区 › MeanStreet

如何处理python3中的错误raise-asyncio

python-asyncio python

MeanStreet · 技术社区 · 5 年前

我有个功能 f() 这就调用了一个API,我想异步地多次调用它。我用 asyncio 像这样:

async def main():
    loop = asyncio.get_event_loop()
    futures = [loop.run_in_executor(None, f) for i in range(10)]
    await asyncio.gather(*futures)
    return futures

result = asyncio.get_event_loop().run_until_complete(main())

问题是有时 F-() 提出一个 Exception 我不知道怎么处理。医生说 Futures 可以包含一个 例外 ,但这里不是这样,错误会出现,程序崩溃。

我怎样才能做到?我想我可以为 F-() 和 try: catch: 例外,但如果该特性是由lib提供的,则看起来很难看。

提前感谢您的帮助,

1 回复 | 直到 5 年前

user4815162342 5 年前

问题是有时 f() 提出一个 Exception 我不知道怎么处理。

这将取决于发生异常时要做什么。记住 asyncio.gather() 是一个方便的API,它在默认情况下传播异常,以避免在出现错误时盲目地继续。如果你希望要在异常情况下继续,您还有其他选项:

通过 return_exceptions=True 到 gather -这将导致 聚集 返回异常对象和其他结果。方便且易于使用,但将异常与常规结果混合在一起,这有点混乱。
使用 asyncio.wait() 而不是 异步收集() . 它返回一组期货 ,您可以测试它们是通过提升还是通过生成结果来完成。
包裹 F-() 在您自己的函数中捕获您认为合适的异常。您考虑过并拒绝了这一点,但在某些情况下,这正是正确的方法。

推荐文章

Sylvain Biehler · PyInstaller导入错误:无法导入名称“SelectorEventLoop”

6 年前

user9342520 · 在从主线程运行的异步IO事件循环中运行无限循环

6 年前

Rotareti · Python asyncio-如何延迟地链()从as\u completed()返回的结果?

6 年前

Michael Fulton · 异步IO。start\u服务器未在pytest asyncio测试内运行

6 年前

Kristy · 无法通过conda安装Asyncio

6 年前

siebz0r ecatmur · wait\uuuu是否需要是生成器?

6 年前

adapap · 不一致py后台任务中断,但任务仍处于挂起状态(使用websocket)

6 年前

Xaztek · 在字典中循环时,Discord Py bot垃圾邮件通道

6 年前

James Ko · 如何在Python中不浪费时间等待许多绑定到网络的任务?

6 年前

antfuentes87 · 如何在另一个异步IO循环中使用异步IO循环

6 年前