Telethon异步Bot遇TimeoutError无法捕获，如何保障listener可靠重启？

我用asyncio开发异步Telegram机器人，给message_listener函数加了重试逻辑处理TimeoutError这类错误，代码里用except Exception as e尝试捕获所有异常，保证listener出错后能重启。但遇到TimeoutError时，任务直接停止，既没触发except块也没重试，心跳任务还在正常运行。

示例日志：

2024-11-13 22:10:05,488:WARNING:Telegram is having internal issues TimeoutError: Timeout while fetching data (caused by GetHistoryRequest)

怀疑任务被静默取消，或者异常没传播到try-except块。关键代码如下：

message_listener函数：

async def message_listener():
    try:
        while True:
            message = await client.get_messages(chat, limit=1)
            # 处理消息逻辑
    except Exception as e:
        # 通用错误处理与重试逻辑

主协程代码：

try:
    await asyncio.gather(
        reading_telegram.message_listener(),
        monitoring_status.send_heartbeat()
    )
except Exception as e:
    logging.exception(f"reading_relegram.py发生错误: {e}")

核心疑问：

1. 怎么确保message_listener遇到TimeoutError或静默停止时能可靠重启？
2. 为什么当前的异常捕获逻辑没生效？
3. 这是Telethon的预期行为吗？

一、异常捕获失效的原因 #

1. 异常作用域错误：你把整个while True循环放在外层try-except中，只有当循环本身因未捕获异常退出时才会触发except块。但Telethon的get_messages抛出的TimeoutError可能被内部处理为警告（如日志中的WARNING输出），并未终止协程；或者异常抛出时，因为try块包裹的是整个循环而非单次调用，导致捕获不到单次请求的异常。
2. 任务静默终止/取消：Telethon对部分临时性错误（如服务器超时）可能不会抛出终止性异常，而是静默终止当前的get_messages调用，甚至直接取消协程任务，这种情况下外层try-except无法捕获到异常。

二、实现可靠重启的方案 #

1. 将异常捕获移至循环内部 #

给每次get_messages调用单独加异常捕获，确保单次错误不会终止整个循环：

async def message_listener():
    while True:
        try:
            message = await client.get_messages(chat, limit=1)
            # 处理消息逻辑
        except TimeoutError as e:
            logging.warning(f"获取消息超时: {e}")
            await asyncio.sleep(5)  # 重试前等待固定时间
        except Exception as e:
            logging.exception(f"消息监听出现未预期错误: {e}")
            await asyncio.sleep(10)  # 非超时错误延长等待时间再重试

2. 增加任务守护重启逻辑 #

用外层协程监控message_listener的运行状态，一旦任务终止就自动重启：

async def run_listener_with_restart():
    while True:
        try:
            await reading_telegram.message_listener()
            logging.warning("消息监听任务意外退出，准备重启...")
        except Exception as e:
            logging.exception(f"消息监听任务崩溃，准备重启: {e}")
        finally:
            await asyncio.sleep(3)  # 重启前的缓冲等待时间

# 主协程中替换为该守护任务
try:
    await asyncio.gather(
        run_listener_with_restart(),
        monitoring_status.send_heartbeat()
    )
except Exception as e:
    logging.exception(f"主协程发生错误: {e}")

3. 适配Telethon的错误处理特性 #

Telethon对部分临时性错误会优先输出警告而非抛出异常，你可以：

• 自定义日志处理器，监听Telethon的WARNING日志，主动触发重试逻辑；
• 调整client的超时配置参数，减少TimeoutError的触发频率；
• 检查get_messages的返回值（如是否为空），判断是否出现异常情况并处理。

三、是否为Telethon的预期行为？ #

是的。Telethon针对Telegram服务器超时这类临时性错误，会优先输出警告而非直接抛出终止性异常，避免协程直接崩溃。但在错误持续发生或遇到严重错误时，仍会抛出异常。你遇到的情况属于Telethon将TimeoutError处理为警告，但内部终止了当前请求，而你的循环因未捕获单次调用异常，导致任务意外停止。

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