如何取消Python asyncio中未被await的协程或抑制相关RuntimeWarning？

好问题！这个RuntimeWarning绝对是异步编程里的常见坑——当你创建了协程对象却从来没await它，Python程序退出时就会跳出来提醒你“浪费资源啦”。针对你的分组查询场景，有两个靠谱的方向解决：要么主动取消未执行的协程，要么（万不得已时）抑制警告，下面具体拆解：

方案一：用asyncio.TaskGroup（Python 3.11+）——首推 #

这是Python官方在3.11版本推出的异步任务管理神器，完美适配你“一组失败就终止所有组”的需求：它会自动接管所有任务的生命周期，一旦某个任务抛出异常，其余未完成的任务会被自动取消，而且不会留下任何未await的协程，从根源上解决警告问题。

修改你的分组执行逻辑如下：

import asyncio

async def execute_queries(self):
    all_results = []
    # 模拟你的多组查询生成逻辑
    query_groups = [
        await self.create_queries('/group1/url'),
        await self.create_queries('/group2/url'),
        await self.create_queries('/group3/url')
    ]
    total_queries = sum(len(group) for group in query_groups)
    done_queries = 0

    async with asyncio.TaskGroup() as tg:
        # 把每组查询提交到TaskGroup，自动转为可管理的任务
        group_tasks = []
        for group in query_groups:
            # 用tg.create_task包装整组查询的gather任务
            group_task = tg.create_task(asyncio.gather(*group))
            group_tasks.append(group_task)
        
        # 等待各组完成，一旦有组失败，TaskGroup会立刻取消所有其他任务
        for task in group_tasks:
            group_results = await task
            # 处理单组结果并更新统计
            for result in group_results:
                if not result['success']:
                    raise QueryException(result['message'])
                done_queries += 1
                _logger.info(f'{done_queries} of {total_queries} queries done')
            all_results.extend(group_results)
    
    return all_results

用TaskGroup的好处太明显了：

• 不用手动跟踪一堆任务，异常处理和任务取消全自动化
• 完全不会触发RuntimeWarning，所有任务都被妥善await
• 代码比手动管理简洁太多，减少出错概率

方案二：手动管理任务并取消（兼容Python 3.7+） #

如果你的Python版本还没升到3.11，也可以手动把协程包装成asyncio.Task对象，在异常发生时主动取消未完成的任务：

import asyncio

async def execute_queries(self):
    query_groups = [
        await self.create_queries('/group1/url'),
        await self.create_queries('/group2/url'),
        await self.create_queries('/group3/url')
    ]
    # 把所有查询协程转为Task，方便跟踪状态和取消
    all_tasks = []
    for group in query_groups:
        group_tasks = [asyncio.create_task(self.run_query(url)) for url in group]
        all_tasks.extend(group_tasks)
    
    total = len(all_tasks)
    done = 0
    results = []
    try:
        # 用as_completed实现并发执行，同时逐个处理结果
        for task in asyncio.as_completed(all_tasks):
            result = await task
            if not result['success']:
                raise QueryException(result['message'])
            done += 1
            _logger.info(f'{done} of {total} queries done')
            results.append(result)
    except QueryException:
        # 遍历所有任务，取消未完成的
        for task in all_tasks:
            if not task.done():
                task.cancel()
                # 必须await已取消的任务，否则还是会触发警告
                try:
                    await task
                except asyncio.CancelledError:
                    pass
        raise  # 重新抛出异常，让上层的run()函数处理
    return results

这里的关键细节是：

• 一定要把协程包装成Task，普通协程没法跟踪状态和取消
• 取消任务后记得await它，否则Python还是会认为这个协程没被妥善处理，警告依然会出现

方案三：抑制警告（不推荐，仅应急） #

如果你暂时没时间重构代码，可以用Python的warnings模块过滤这个特定警告，但这属于“掩盖问题”而非“解决问题”——它会忽略所有同类警告，可能让你错过其他真正的未await协程错误：

import warnings
import asyncio

def main():
    # 在程序入口过滤指定警告
    warnings.filterwarnings(
        "ignore",
        category=RuntimeWarning,
        message="coroutine.*was never awaited"
    )
    asyncio.run(run())

⚠️ 强烈建议只在临时调试时用这个方案，长期来看还是优先用前两种任务管理的方式。

最后提一句：你原始代码里用for循环逐个await协程的写法，其实并没有真正利用异步的并行优势，实际场景一定要用asyncio.gather或者asyncio.as_completed才能让查询并发执行，这部分你已经提到了，就不多啰嗦啦。

内容的提问来源于stack exchange，提问作者Mr.Manhattan