调度器相关方法
添加任务
在这个部分,我们有一个方法用于添加调度任务。你可以通过传递不同的参数,比如函数 func、触发器 trigger、参数 args 和 kwargs 等,来定义一个新的调度任务。
def add_job(self, func, trigger=None, args=None, kwargs=None, id=None, name=None, misfire_grace_time=undefined, coalesce=undefined, max_instances=undefined, next_run_time=undefined, jobstore='default', executor='default', replace_existing=False, **trigger_args):
修改任务
这部分包括了两个方法,一个是修改任务,一个是重新调度任务。你可以通过传递任务的标识 job_id 以及一些需要修改的参数,来对现有的任务进行修改或者重新调度。
def modify_job(self, job_id, jobstore=None, **changes): def reschedule_job(self, job_id, jobstore=None, trigger=None, **trigger_args):
移除任务
这里有两个方法,一个是移除指定任务,一个是移除所有任务。你可以通过传递任务的标识 job_id 来移除指定任务,或者直接移除所有任务。
def remove_job(self, job_id, jobstore=None): def remove_all_jobs(self, jobstore=None):
暂停恢复任务
在这部分,我们有两个方法,一个是暂停指定任务,一个是恢复指定任务。通过传递任务的标识 job_id,你可以控制任务的暂停和恢复。
def pause_job(self, job_id, jobstore=None): def resume_job(self, job_id, jobstore=None):
获取任务
这里包括两个方法,一个是获取所有任务,一个是获取指定任务。你可以通过传递任务的标识 job_id 或者指定的调度器 jobstore 来获取相应的任务。
def get_jobs(self, jobstore=None, pending=None): def get_job(self, job_id, jobstore=None
打印任务
这个方法用于打印任务的相关信息,可以选择指定的调度器 jobstore 以及输出位置 out。
def print_jobs(self, jobstore=None, out=None):
调度器相关方法
最后,这里有一些调度器的相关方法。你可以获取调度器的状态、暂停和恢复整个调度器、启动调度器以及关闭调度器。
# 获取调度器状态 scheduler.state # 暂停调度器 scheduler.pause() # 恢复调度器 scheduler.resume() # 启动调度器 scheduler.start() # 关闭调度器,关闭后不可再启动 scheduler.shutdown()