如何在特定的时间和间隔内调度作业？

Question

使用python的调度模块，我如何在特定时间启动作业，并在此基础上定期调度作业。

假设我想要从上午09:00开始每4小时安排一次任务

schedule.every(4).hours.at("09:00").do(task) # This doesn't work

如何实现上述目标？

Answer 1

您可以将内部日程表(每4小时)转换为一个单独的函数，该函数将由主日程表(固定时间)调用。内部调度函数将调用您的作业函数。

示例：

import schedule
import time

def job():
    print "I am working" #your job function

def schedule_every_four_hours():
    job() #for the first job to run
    schedule.every(4).hour.do(job)
    return schedule.CancelJob

schedule.every().day.at("09:00").do(schedule_every_four_hours)

while True:
    schedule.run_pending()
    time.sleep(1)

如果你想终止基于你的需求的时间表，请在这里阅读更多。Check here。

Answer 2

如果有多个调度，上述解决方案将不起作用，因为schedule.CancelJob会取消管道上的其他调度，最好使用clear标签

import schedule
from datetime import  datetime
import time
def task():
    print 'I am here...',datetime.now()

def schedule_every_four_hours(clear):
    if clear =='clear':
        schedule.every(2).seconds.do(task).tag('mytask1') #for the first job to runschedule.every(4).hour.at("9:00").do(task)
    else:
        schedule.every(5).seconds.do(task).tag('mytask2')  # for the second job to runschedule.every(4).hour.at("9:00").do(task)
    print clear
    schedule.clear(clear)

now = datetime.now()


times = str(now.hour+0)+ ":"+str(now.minute+1)

times1 = str(now.hour+0)+ ":"+str(now.minute+3)
schedule.every().day.at(times).do(schedule_every_four_hours,'clear').tag('clear')


schedule.every().day.at(times1).do(schedule_every_four_hours,'clear1').tag('clear1')



while True:
    schedule.run_pending()
    time.sleep(1)