如何同时调度异步与同步函数？APScheduler+python-telegram-bot问题

核心问题原因 #

1. BackgroundScheduler：基于线程池实现，直接调用异步函数时不会自动处理await，导致异步任务仅被调用但未实际执行，触发未await警告。
2. AsyncIOScheduler：基于asyncio事件循环，直接添加同步任务会阻塞事件循环，导致同步任务无法正常执行；异步函数内直接调用同步函数同理，会卡死事件循环。

可行实现方案 #

由于python-telegram-bot v20+为全异步架构，优先使用AsyncIOScheduler统一调度，通过异步包装器处理同步函数，避免阻塞事件循环。

代码示例 #

import asyncio
from apscheduler.schedulers.asyncio import AsyncIOScheduler
from telegram import Bot

# 你的同步任务函数
def function_one():
    print("[同步任务] 执行function_one")
    # 这里写同步逻辑，比如数据同步、文件操作等

# 依赖Bot的异步任务函数
async def function_two(bot: Bot):
    print("[异步任务] 执行function_two")
    # 示例：发送Telegram消息，需await
    await bot.send_message(chat_id="你的聊天ID", text="异步任务已执行")

# 同步函数的异步包装器：用asyncio.to_thread将同步逻辑放到线程池执行
async def wrap_sync_function():
    await asyncio.to_thread(function_one)

async def main():
    # 初始化Telegram Bot
    bot = Bot(token="你的Bot Token")
    
    # 初始化AsyncIOScheduler，指定时区
    scheduler = AsyncIOScheduler(timezone="Asia/Shanghai")
    
    # 添加同步任务（使用包装后的异步函数）
    scheduler.add_job(wrap_sync_function, "interval", seconds=10)
    
    # 添加异步任务，直接传入函数和参数
    scheduler.add_job(function_two, "interval", seconds=15, args=(bot,))
    
    # 启动调度器
    scheduler.start()
    
    try:
        # 保持事件循环持续运行（直到Ctrl+C中断）
        await asyncio.Event().wait()
    except KeyboardInterrupt:
        # 优雅关闭调度器和Bot
        scheduler.shutdown()
        await bot.close()

if __name__ == "__main__":
    asyncio.run(main())

方案说明 #

1. 同步函数包装：使用asyncio.to_thread()将同步函数放到独立线程执行，既不阻塞asyncio事件循环，又能让AsyncIOScheduler正常调度。
2. 异步函数直接调度：AsyncIOScheduler会自动处理异步任务的await逻辑，符合python-telegram-bot的异步要求。
3. 事件循环保持运行：通过asyncio.Event().wait()让主事件循环持续运行，确保调度器一直工作。

注意事项 #

• 如果同步函数执行耗时较长，可自定义线程池限制线程数量，避免资源耗尽：

  from concurrent.futures import ThreadPoolExecutor
  
  # 初始化自定义线程池（比如最多5个线程）
  thread_pool = ThreadPoolExecutor(max_workers=5)
  
  async def wrap_sync_function():
      await asyncio.get_event_loop().run_in_executor(thread_pool, function_one)
  

• 不要混用BackgroundScheduler和AsyncIOScheduler，会导致事件循环冲突，尤其是在python-telegram-bot的异步环境下。

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