Python调度任务触发OverflowError: sleep length is too large问题求助

我读取.ics文件作为输入，想在事件开始前2小时设置提醒。调试调度器时遇到错误：OverflowError: sleep length is too large。推测是未来过远的事件导致的（日常会每日检查未来24小时的事件，但还是想找到解决办法）。

我的代码如下：

def handle_event(component_event):
    print("event name " + component_event.name)

    scheduler = sched.scheduler(time_module.time, time_module.sleep)

    start = component_event.decoded("dtstart")
    # TODO subtract 2h
    t = time_module.strptime(start.strftime('%Y-%m-%d %H:%M:%S'), '%Y-%m-%d %H:%M:%S')
    t = time_module.mktime(t)

    scheduler.enterabs(t, 1, say_hi, ('hi',))
    scheduler.run()

我试过调整日期格式、以字符串传递等方式，但没解决问题。完整回溯信息：

in check calendar
last processed = 37
test VEVENT
2024-05-25 22:00:00+00:00
1716660000.0 ### this is the time delay printed
Exception in thread Thread-1 (handle_round):
Traceback (most recent call last):
  File "C:\Program Files\WindowsApps\PythonSoftwareFoundation.Python.3.10_3.10.3056.0_x64__qbz5n2kfra8p0\lib\threading.py", line 1016, in _bootstrap_inner
    self.run()
  File "C:\Program Files\WindowsApps\PythonSoftwareFoundation.Python.3.10_3.10.3056.0_x64__qbz5n2kfra8p0\lib\threading.py", line 953, in run
    self._target(*self._args, **self._kwargs)
  File "D:\Coding\FantacalcioHelper\src\utilities\fantasy_football_utilities.py", line 67, in handle_round
    scheduler.run()
  File "C:\Program Files\WindowsApps\PythonSoftwareFoundation.Python.3.10_3.10.3056.0_x64__qbz5n2kfra8p0\lib\sched.py", line 149, in run
    delayfunc(time - now)
OverflowError: sleep length is too large

问题原因 #

time.sleep()的参数存在最大值限制（Windows系统下约为49天），当目标事件距离当前时间超过这个阈值时，就会触发该错误。

解决方案 #

1. 过滤超远期事件（符合你的日常逻辑）

直接跳过未来超过24小时的事件，只处理近期任务，避免调度过远的任务触发错误：

import time as time_module
import sched

def handle_event(component_event):
    print("event name " + component_event.name)

    scheduler = sched.scheduler(time_module.time, time_module.sleep)
    start = component_event.decoded("dtstart")
    
    # 处理时区并转换为UTC时间戳，替代冗余的字符串转换操作
    utc_start = start.astimezone(time_module.timezone.utc)
    event_timestamp = utc_start.timestamp()
    
    # 计算提前2小时的提醒时间
    reminder_timestamp = event_timestamp - 2 * 3600
    current_timestamp = time_module.time()
    
    # 只处理未来24小时内的提醒任务
    if reminder_timestamp - current_timestamp <= 24 * 3600:
        if reminder_timestamp > current_timestamp:
            scheduler.enterabs(reminder_timestamp, 1, say_hi, ('hi',))
            scheduler.run()
        else:
            print("事件已过期，无需设置提醒")
    else:
        print("事件超过24小时范围，暂不设置提醒")

def say_hi(msg):
    print(msg)

2. 分阶段睡眠（如需处理超远期事件）

如果必须处理超过49天的远期事件，不要让调度器一次性睡眠太久，而是拆分睡眠时间，每次睡眠固定时长后重新检查：

def run_scheduler_with_split_sleep(scheduler):
    while scheduler.empty() is False:
        now = time_module.time()
        event = scheduler.queue[0]
        delay = event.time - now
        # 每次最多睡眠1小时（3600秒）
        if delay > 3600:
            time_module.sleep(3600)
        else:
            scheduler.run()
            break

# 在handle_event中替换scheduler.run()为该函数
run_scheduler_with_split_sleep(scheduler)

3. 使用更专业的调度库

推荐使用APScheduler，它原生支持远期任务调度，内部会自动管理睡眠周期，无需手动处理阈值问题：

from apscheduler.schedulers.background import BackgroundScheduler

def handle_event(component_event):
    print("event name " + component_event.name)
    start = component_event.decoded("dtstart")
    reminder_time = start - time_module.timedelta(hours=2)
    
    scheduler = BackgroundScheduler()
    scheduler.add_job(say_hi, 'date', run_date=reminder_time, args=('hi',))
    scheduler.start()

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