如何使用python重新启动mysql中保存的调度器

2024-04-26 04:57:04 发布

您现在位置:Python中文网/ 问答频道 /正文

使用以下代码,我将jobstore保存在我的mysql数据库中进行测试。你知道吗

from apscheduler.schedulers.background import BlockingScheduler

def tick ():
    print ("Hi")

sched = BlockingScheduler()
url = 'mysql://myname:mypw@localhost/rssdb'
sched.add_jobstore('sqlalchemy', url=url)
sched.add_job(tick,'interval',seconds=10)
sched.start()

我已检查它是否正确保存,并希望加载和执行作业。 我该怎么办?你知道吗


Tags: 代码fromimportadd数据库urldefmysql
1条回答
网友
1楼 · 发布于 2024-04-26 04:57:04

如果作业被保存到mysql中 你可以做以下事情。添加作业时,还应包括要添加的作业库。您还可以将其他选项(如job\u defaults)与job\u存储一起添加到调度程序

from apscheduler.schedulers.background import BlockingScheduler

def tick ():
   print ("Hi")

jobstores = {
        'sqlalchemy': SQLAlchemyJobStore(url='mysql://myname:mypw@localhost/rssdb')
}
sched = BlockingScheduler(jobstores=jobstores)
sched.start()
#to add a job you better also say which jobstore you want to add it
sched.add_job(tick,'interval',seconds=10, jobstore='sqlalchemy')

相关问题 更多 >