如何用asyncio实现Discord Bot后台执行耗时任务？

核心问题 #

你遇到的问题根源在于：googleapiclient的execute()是同步阻塞方法，即便你把它放在async函数中并使用await，也无法让它让出asyncio事件循环。你的search_yt_helper虽然定义为async函数，但内部调用的Comments.youtube_search_keyword和youtube_get_comments本质是同步阻塞操作，会完全卡住事件循环，导致其他命令（如short_method）必须等长任务结束才能被处理。

另外你还有一个小疏漏：search_yt_helper最后一行的ctx.send()没有添加await，这会导致消息无法正确发送，还会触发运行时警告。

解决方案 #

将所有同步阻塞的API调用包装到线程池中执行，让阻塞操作在后台线程运行，不占用事件循环。Python 3.9+可以用asyncio.to_thread()，更低版本可以用loop.run_in_executor()。

代码修改示例 #

1. 修正search_yt_helper方法，用线程池包装同步调用：

import asyncio

async def search_yt_helper(self, query, confirmation_ctx):        
    # 将同步搜索任务放到线程池执行
    video_ids, video_titles, channels = await asyncio.to_thread(
        Comments.youtube_search_keyword, self.api_key, query, max_results=5
    )
    n = 0
    new_comments = pd.DataFrame()
    logging.info(f"got {len(video_ids)} results")
    
    # 每个视频的评论获取也放到线程池
    for v_id in video_ids:
        c = await asyncio.to_thread(
            Comments.youtube_get_comments, self.api_key, v_id, scrolls=3
        )
        n += len(c)
        temp = pd.DataFrame(c, columns=['comment'])
        new_comments = pd.concat([new_comments, temp], ignore_index=True)

    self.comments = pd.concat([new_comments, self.comments], ignore_index=True)
    
    # 补上await，确保消息发送完成
    await confirmation_ctx.send(f"added {n} comments from query")

2. 简化long_method的任务创建：

@commands.command()
async def long_method(self, ctx, params):
    await ctx.send("starting long method")
    # 直接创建异步任务，无需手动获取事件循环
    asyncio.create_task(self.search_yt_helper(params, ctx))

原理说明 #

asyncio.to_thread()会把同步函数提交到线程池执行，事件循环会在等待线程完成的过程中处理其他异步任务（比如short_method的请求），这样你的Bot就能在下载评论的同时响应其他命令，达到你期望的输出顺序。

内容的提问来源于stack exchange，提问作者nikhilk