python - 如何集成APScheduler和Imp？

Question

我构建了一个基于插件的应用程序，其中“插件”(python 模块)可以由 imp 加载，然后安排由 APScheduler 稍后执行，我能够成功集成它们，但我想在崩溃时实现持久性或者应用程序重新启动，所以我将默认的内存作业存储更改为SqlAlchemyJobStore，它在第一次执行程序时运行得很好:任务被加载、调度、保存在数据库中并在正确的时间执行。

问题是当我尝试再次加载应用程序时，我得到了这个回溯:

ERROR:apscheduler.jobstores.default:Unable to restore job "d3e0f0068df54d15986e9b7b6757f665" -- removing it
Traceback (most recent call last):
  File "/home/jesus/.local/lib/python2.7/site-packages/apscheduler/jobstores/sqlalchemy.py", line 126, in _get_jobs
jobs.append(self._reconstitute_job(row.job_state))
  File "/home/jesus/.local/lib/python2.7/site-packages/apscheduler/jobstores/sqlalchemy.py", line 114, in _reconstitute_job
job.__setstate__(job_state)
File "/home/jesus/.local/lib/python2.7/site-packages/apscheduler/job.py", line 228, in __setstate__
self.func = ref_to_obj(self.func_ref)
  File "/home/jesus/.local/lib/python2.7/site-packages/apscheduler/util.py", line 257, in ref_to_obj
raise LookupError('Error resolving reference %s: could not import module' % ref)
LookupError: Error resolving reference __init__:run: could not import module

所以很明显，尝试再次导入该函数时出现了问题

这是我的调度程序初始化:

    executors = {'default': ThreadPoolExecutor(5)}
    jobstores = {'default': SQLAlchemyJobStore(url='sqlite:///jobs.sqlite')}
    self.scheduler = BackgroundScheduler(executors = executors,jobstores=jobstores)

我有一个“tests”字典，其中包含应加载的“插件”和一些参数，“load_plugin”使用 imp 按名称加载插件。

for test,parameters in tests.items():
        if test in pluggins:
            module=load_plugin(pluggins[test])
            self.jobs[test]=self.scheduler.add_job(module.run,"interval",seconds=parameters["interval"],name=test)

知道如何处理重组工作吗？

Answer 1

自动检测模块名称时出现问题。很难说是什么，但另一种方法是手动为其提供正确的查找路径作为字符串(例如“package.module:function”)。如果你能做到这一点，就可以避免这个问题。