Asyncio等待处理异常有时会失败？答案

【问题标题】：Asyncio wait handling Exception sometimes fails?Asyncio等待处理异常有时会失败？
【发布时间】：2021-09-28 14:38:16
【问题描述】：

我已经设置了一个异步循环来创建具有限制的任务列表。

        while current_index < len(numbers):
            if len(tasks) >= NO_CONCURRENT:
                _done, tasks = await asyncio.wait(tasks, return_when=asyncio.FIRST_COMPLETED)
                task: Task = next(iter(_done))
                
                try:
                    task.result()
                except Exception as e:
                    logging.error(f"Error: occured {e}")
                    results.append(task.exception())
                else:
                    results.append(task.result())

它有时会成功处理异常（也会记录错误）但有时甚至不处理它只是打印出异常（不记录它）

例子

2021-07-21,03:53:55.082 ERROR {base_events} [default_exception_handler] Task exception was never retrieved
future: <Task finished name='Task-16' coro=<AutoPart.get_all_info() done, defined at /mnt/d/PythonProjects/btyu-part-num-search/copy_main.py:258> exception=PartNumberNotFound('Part number 14111047 is NOT Found.')>
Traceback (most recent call last):
  File "/mnt/d/PythonProjects/btyu-part-num-search/copy_main.py", line 260, in get_all_info
    listing_container_id_num = await self.get_part_number(session)
  File "/mnt/d/PythonProjects/btyu-part-num-search/copy_main.py", line 141, in get_part_number
    raise PartNumberNotFound(self.part_number)
copy_main.PartNumberNotFound: Part number 14112106479456 is NOT Found.

【问题讨论】：

标签： python exception async-await task python-asyncio

【解决方案1】：

当两个任务碰巧在同一个事件循环迭代中完成时，您的代码无法处理这种情况。在这种情况下，asyncio 返回的done 集合将包含多个元素，尽管请求了“第一个”完成。在这种情况下，您将只能访问第一个任务的结果，而第二个任务将在没有任何人访问其异常的情况下被销毁，正如警告正确指出的那样。

你应该用循环来处理它：

while current_index < len(numbers):
    if len(tasks) >= NO_CONCURRENT:
        done, _ = await asyncio.wait(tasks, return_when=asyncio.FIRST_COMPLETED)
        for task in done:
            try:
                task.result()
            except Exception as e:
                logging.error(f"Error: occured {e}")
                results.append(task.exception())
            else:
                results.append(task.result())

另外，请注意变量名前面的初始_ 是您不使用的值的约定，而不是您使用的值。

【讨论】：