python - 先进的Python Scheduler和SQLAlchemyJobStore

我在APS中使用sqlalchemy作业存储。使用函数add_cron_job添加的作业太过cron。但数据库表中没有任何条目。请帮助我：下面是代码

import time
import logging
from threading import Timer
from threading import Lock
from gadgetplatform.classes.utils.utilities import import_module
from apscheduler.scheduler import Scheduler

from apscheduler.jobstores.sqlalchemy_store import SQLAlchemyJobStore

class SchedulerManager(object):
    _instance = None
    _initialised = False
    lock = Lock()
    log = logging.getLogger(__name__)
    jobDict=[]

    def __new__(cls):

        if not cls._instance or not cls._initialised:
            cls.lock.acquire()
            if not cls._instance:
                cls.log.info("creating instance")
                cls._instance = super(SchedulerManager, cls).__new__(cls)
                cls._initialised = True
                cls._instance.init()
                cls.log.info("instance created")
            cls.lock.release()
            cls.log.info("lock released")
            cls.log.info("returning instance")
        return cls._instance

    def init(self):
        self.sched=Scheduler()
        self.sched.add_jobstore(SQLAlchemyJobStore('mysql://root@localhost/mygola?charset=utf8&use_unicode=0'), 'apschedulerJobs')

    def addToCron(self,source,time):
        self.log.info("called to add schedular")

        time = time.split(' ')

        m=str(time[0])
        h=str(time[1])
        d=str(time[2])
        mnth=str(time[3])
        yr=str(time[4])

        func=self.convertStringToFunction(source)
        self.sched.add_cron_job(func, year=yr, month=mnth, day=d, hour=h, minute=m)
        self.jobDict.append(source)

        self.log.info("added with the time")

    def removeFromCron(self,source):
        func=self.convertStringToFunction(source)
        self.sched.unschedule_func(func)

    def start(self):
        self.sched.start()
        self.log.info("Schedular Started")

    def stop(self):
        self.sched.shutdown()

    def getRunningJobs(self):
        return self.jobDict

    def convertStringToFunction(self,source):
        strArr = source.rsplit('.',1)
        mod = import_module(strArr[0])
        func = getattr(mod, strArr[1])
        return func

最佳答案

我从未使用过APScheduler，但从文档来看，似乎必须指定要向哪个作业存储添加作业。
您可以通过给SQL炼金术作业存储指定特殊名称来确保它是默认存储：

self.sched.add_jobstore(SQLAlchemyJobStore('...'), 'default')

或者可以在添加作业时指定作业存储名称：

self.sched.add_cron_job(func,
                        jobstore="apschedulerJobs",
                        year=yr, month=mnth, day=d, hour=h, minute=m)

关于python - 先进的Python Scheduler和SQLAlchemyJobStore，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/10104682/