0

问题陈述：

我正在尝试添加一个方法 ( Test::start())，scheduler.add_date_job()该方法被配置为将作业存储在SQLAlchemyJobStore作业商店中。将作业添加到作业存储成功。但是当我尝试启动调度程序时，obj_to_ref(in apscheduler/util.py) 无法获取ref_to_obj()给定对象的 [在这种情况下，给定对象是Test::start()- 换句话说，<bound method Test.start of <__main__.Test instance at 0xa119a6c>>]。

但是在以下情况下，相同的操作可以正常工作：

  1. 其他作业存储（fe RAMJobStore- 这是未添加/配置作业存储时的默认设置）。
  2. 当scheduler.add_date_job()使用其他函数（func下面代码中的 fe）而不是像Test::start()（作业商店是SQLAlchemyJobStore）[the ref_to_obj()and obj_to_ref()for funcis <function func at 0xb768ed14>] 之类的方法调用时。我添加了一些调试（在 中apscheduler/util.py）以确认相同。

代码如下：

from apscheduler.scheduler import Scheduler as scheduler
from datetime import datetime, date, time, timedelta
import time
import logging

logging.basicConfig(filename='/tmp/log', level=logging.DEBUG,
        format='[%(asctime)s]: %(levelname)s : %(message)s')

class Failed(Exception):
    def __str__(self):
        return 'Failed!!'

# APScheduler Configure Options
_g_aps_default_config = {
    'apscheduler.standalone' : True,
    'apscheduler.jobstore.default.class' : 'apscheduler.jobstores.sqlalchemy_store:SQLAlchemyJobStore',
    'apscheduler.jobstore.default.url' : 'mysql://root:root123@localhost/jobstore',
    'apscheduler.jobstore.default.tablename' : 'mytable'
}

class Test:
    def __init__(self, *args, **kwargs):
        self.scheduler = scheduler(_g_aps_default_config)
        self.__running = False
        # Intentionally don't want to start!!
        self.__dont_start = True 
        self.__retry_count = 0
        self.__start_max_retries = 5

    def start(self):
        try:
            # Try to start here! 
            # Intentionally don't want to start for the first 5 times
            if self.__retry_count < self.__start_max_retries:
                self.__retry_count += 1
                raise Failed
            if self.__running:
                raise Failed
            self.__running = True
            print 'started successfully :)'
        except Failed:
            # log the start failure and reschedule the start()
            print 'attempt (#%d): unable to start now.. ' \
                  'so rescheduling to start after 5 seconds' % self.__retry_count
            alarm_time = datetime.now() + timedelta(seconds=5)
            self.scheduler.add_date_job(self.start, alarm_time)
            self.scheduler.start()

def func():
    print 'this is a func and not a method!!!'

if __name__ == '__main__':
    t = Test()
    t.start()
    while True:
        time.sleep(10)
    t.stop()

堆栈跟踪如下：

Traceback (most recent call last):
  File "user1.py", line 55, in <module>
    t.start()
  File "user1.py", line 48, in start
    self.scheduler.start()
  File "/usr/lib/python2.7/site-packages/APScheduler-2.1.0-py2.7.egg/apscheduler/scheduler.py", line 109, in start
    self._real_add_job(job, jobstore, False)
  File "/usr/lib/python2.7/site-packages/APScheduler-2.1.0-py2.7.egg/apscheduler/scheduler.py", line 259, in _real_add_job
    store.add_job(job)
  File "/usr/lib/python2.7/site-packages/APScheduler-2.1.0-py2.7.egg/apscheduler/jobstores/sqlalchemy_store.py", line 58, in add_job
    job_dict = job.__getstate__()
  File "/usr/lib/python2.7/site-packages/APScheduler-2.1.0-py2.7.egg/apscheduler/job.py", line 120, in __getstate__
    state['func_ref'] = obj_to_ref(self.func)
  File "/usr/lib/python2.7/site-packages/APScheduler-2.1.0-py2.7.egg/apscheduler/util.py", line 174, in obj_to_ref
    raise ValueError('Cannot determine the reference to %s' % repr(obj))
ValueError: Cannot determine the reference to <bound method Test.start of <__main__.Test instance at 0xa119a6c>>

我添加的调试apscheduler/util.py如下：

161 def obj_to_ref(obj):
162     """
163     Returns the path to the given object.
164     """
165     ref = '%s:%s' % (obj.__module__, get_callable_name(obj))
166     print 'obj_to_ref : obj : %s' % obj
167     print 'obj_to_ref : ref : %s' % ref
168     try:
169         obj2 = ref_to_obj(ref)
170         print 'obj_to_ref : obj2 : %s' % obj2
171         if obj != obj2:
172             raise ValueError
173     except Exception:
174         raise ValueError('Cannot determine the reference to %s' % repr(obj))
175 
176     return ref

以下是 的调试打印Test::start()：

obj_to_ref : obj : <bound method Test.start of <__main__.Test instance at 0xa119a6c>>
obj_to_ref : ref : __main__:Test.start
obj_to_ref : obj2 : <unbound method Test.start>

将 更改scheduler.add_date_job()为function(fe func) 而不是method(fe Test::start())

self.scheduler.add_date_job(func, alarm_time)

以下是 的调试打印func()：

obj_to_ref : obj : <function func at 0xb768ed14>
obj_to_ref : ref : __main__:func
obj_to_ref : obj2 : <function func at 0xb768ed14>

我在这里做错了吗？还是这是apscheduler/util.py函数 wrt中的错误SQLAlchemyJobStore？

任何已知的解决方法？！

4

1 回答 1

1

主要问题是当您使用SQLAlchemyJobStore或任何其他作业存储RAMJobStore时，apscheduler 使用 pickle 序列化您的作业以将其保存到存储中。它仅将引用名称保存到您在scheduler.add_date_job方法中指定的函数。

因此，在您的情况下，它可以保存类似<object id in memory>.start.

因此，对于工作职能，您应该使用在模块顶层定义的函数，而不是实例方法。

这也意味着 apscheduler 不会在运行之间保存作业功能状态。您可能需要在方法内部实现将状态保存和加载到数据库中。但这会使事情变得过于复杂。

更好的方法是实现自定义调度触发器类，该类将决定何时运行作业。您可能仍需要加载/保存触发器的状态 - 因此它将支持停止和启动调度程序进程。

一些链接：

于 2013-02-12T04:26:52.730 回答