使用mongodb的apscheduler

Question

我正在尝试运行以下代码：

from pytz import utc
from apscheduler.schedulers.background import BackgroundScheduler
from apscheduler.jobstores.mongodb import MongoDBJobStore

jobstores = {
  'default': MongoDBJobStore(database='apscheduler', collection='jobs', host='xxx', port=27017)
}
sched = BackgroundScheduler(jobstores=jobstores)
@sched.scheduled_job('interval', seconds=1)
def job():
    print 'This job is run every second.'

sched.start()

但get错误: ValueError:此作业无法序列化，因为无法确定对其callable ()的引用。可以考虑给出一个文本引用(module:函数名)。

Answer 1

问题是我使用了装饰器scheduled_job。