如何在Python中高效处理异步操作？

Question

我尝试过的：

我尝试使用 asyncio 在 Python 中实现异步操作，特别是为了利用并发任务执行的力量。我的代码涉及由 asyncio.gather 管理的多个异步函数。目标是在同时处理各种任务时实现并行性和效率。

import asyncio

async def task_one():
    # Asynchronous code for task one

async def task_two():
    # Asynchronous code for task two


try:
    await asyncio.gather(task_one(), task_two(), ...)
except Exception as e:
    # Handling exceptions during task execution
    print(f"An error occurred: {e}")

发生了什么：

在执行异步任务时，我遇到了与错误处理相关的挑战。当其中一项任务发生异常时，就会中断整个事件循环。这种行为使得很难优雅地处理错误并继续完成剩余的任务。

我期望有一个更具弹性的错误处理机制，使我能够识别和解决各个任务中的错误，而不影响整个过程。我当前的实现无法提供所需的稳健性。

我正在寻求有关改进 asyncio 中错误处理方法的指导，确保其他任务的执行在发生异常时不会中断。

Answer 1

在问题的代码中，这种格式效果很好。

import asyncio

async def task_one():
    print("One")

async def task_two():
    print("Two")

async def main():
    await asyncio.gather(task_one(), task_two())

if __name__ == "__main__":
    asyncio.run(main())

返回这个：

One
Two