问题描述
我正在使用 apscheduler python 库来安排作业。它有工作场所 nextruntime 被存储。我的问题是我们如何添加各个作业存储的更多详细信息。我分享了一张图片,说明它现在的存储方式。
mongo= MongoClient("localhost",27017)
job_stores = {
'default': MongoDBJobStore(database="logs",client=mongo,collection="schedulejob")
}
executors = {
'default': {'type': 'threadpool','max_workers': 60}
}
job_defaults = {
'coalesce': True,# When the same task is triggered multiple times at the same time,it runs only once
'max_instances': 3,'misfire_grace_time': 30,# The task is still executed after 30 seconds of expiration
}
sched = BackgroundScheduler(jobstores=job_stores,executors=executors,job_defaults=job_defaults,daemon=True)
sched.add_job(syncdata,'interval',minutes=5,kwargs={"subdomain": "d3v-digite","emailid": "sp"},name="incrementaljob")
sched.add_listener(listen,EVENT_JOB_EXECUTED | EVENT_JOB_ERROR)
sched.start()
在 mongojob 商店中存储以下内容:
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)