使用APScheduler无法调度任务：select()列参数报错求助

错误原因分析 #

该报错源于APScheduler 3.10.4的SQLAlchemyJobStore查询逻辑与SQLAlchemy 1.3.23的语法存在兼容性冲突，或是自定义任务表结构不符合APScheduler的预期规范。

具体解决建议 #

1. 移除自定义任务表依赖（优先尝试） #

若无需自定义APScheduler任务表，直接使用默认表结构即可解决问题。修改jobstores初始化代码，并删除自定义表的导入：

# 移除这一行导入
# from model import db, app, APSchedulerJobsTable

# 初始化调度器时使用默认表配置
jobstores = {
    'default': SQLAlchemyJobStore(
        url=app.config['SQLALCHEMY_DATABASE_URI'],
        tablename='apscheduler_jobs'  # 让APScheduler自动管理表结构
    )
}

2. 修正自定义任务表结构（若必须使用自定义表） #

确保自定义表结构与APScheduler内置的JobModel完全一致，示例如下：

# 在model.py中定义正确的任务表
from sqlalchemy import Column, String, Float, LargeBinary
from model import db

class APSchedulerJobsTable(db.Model):
    __tablename__ = 'apscheduler_jobs'

    id = Column(String(191), primary_key=True)
    next_run_time = Column(Float, nullable=True)  # 注意：此处需用Float类型而非DateTime
    job_state = Column(LargeBinary, nullable=False)

然后在初始化SQLAlchemyJobStore时指定自定义model：

jobstores = {
    'default': SQLAlchemyJobStore(
        url=app.config['SQLALCHEMY_DATABASE_URI'],
        model=APSchedulerJobsTable
    )
}

3. 调整版本兼容性 #

方案A：降级APScheduler到兼容SQLAlchemy 1.3的版本

执行命令：

pip install apscheduler==3.9.0

方案B：升级SQLAlchemy到兼容APScheduler 3.10.x的版本

执行命令：

pip install sqlalchemy==1.4.49

4. 补充：确保Flask应用上下文正确 #

启动调度器时需在Flask应用上下文内执行，修改run_thread函数：

def run_thread():
    with app.app_context():
        scheduler_thread = Thread(target=start_scheduler)
        scheduler_thread.daemon = True
        scheduler_thread.start()

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