Discord机器人gateway阻塞超10秒，求助排查解决方法

核心问题原因 #

这个discord.gateway警告的本质是asyncio事件循环被阻塞超过10秒，导致Discord网关的心跳包无法按时发送触发告警。虽然日志仅指向启动代码asyncio.run(main())，但阻塞源头一定是你业务逻辑中的同步阻塞操作。从日志里的parse_message_create和dispatch('message')可以看出，阻塞发生在处理message事件的流程中。

排查步骤 #

• 聚焦message相关逻辑：优先检查所有on_message事件处理函数、以及响应消息的命令函数，阻塞大概率出现在这些代码里。
• 检查同步阻塞代码：在上述函数中寻找以下类型的代码：
  • 长时间同步IO操作：比如用requests.get()发起网络请求、大文件同步读写、同步数据库查询
  • 密集计算任务：大数据量循环、复杂加密/解密运算
  • 错误使用time.sleep()：在异步函数中调用同步sleep会直接挂起事件循环
• 用调试工具定位阻塞点：给事件循环添加调试钩子，打印长时间运行的任务：

  import asyncio
  import time
  
  def detect_long_running_tasks():
      for task in asyncio.all_tasks():
          if task._state == 'running':
              elapsed = time.time() - task._created
              if elapsed > 5:
                  print(f"⚠️ 任务 [{task.get_name()}] 已运行 {elapsed:.2f} 秒，疑似阻塞事件循环")
      # 每隔1秒检查一次
      asyncio.get_event_loop().call_later(1, detect_long_running_tasks)
  
  # 在main函数启动机器人前调用
  detect_long_running_tasks()
  

解决方法 #

• 替换同步IO为异步实现：用aiohttp替代requests发起网络请求，用异步数据库驱动（如asyncpg替代psycopg2）
• 将阻塞任务移至线程/进程池：用loop.run_in_executor把同步阻塞任务丢到单独线程，避免占用事件循环：

  import concurrent.futures
  
  async def handle_message(message):
      # 定义同步阻塞函数
      def heavy_task():
          # 这里是密集计算或同步IO操作
          time.sleep(10)
          return "处理完成"
      
      # 提交到线程池执行
      loop = asyncio.get_event_loop()
      result = await loop.run_in_executor(None, heavy_task)
      await message.channel.send(result)
  

• 替换time.sleep()：异步函数中必须用await asyncio.sleep(xxx)替代同步time.sleep()
• 拆分长任务：如果有循环处理大量数据，将循环拆分为小块，每次处理后添加await asyncio.sleep(0)主动让出事件循环

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