Планирование работы с Python с помощью apscheduler и вход в mongodb - PullRequest
0 голосов
/ 18 сентября 2018

Я пытаюсь запланировать работу Python с помощью apscheduler, используя BackgroundScheduler, и регистрирую его с помощью клиента pymongo.

Не уверен, почему он ничего не регистрирует:

from pytz import utc
from apscheduler.schedulers.background import BackgroundScheduler
from apscheduler.executors.pool import ProcessPoolExecutor
from pymongo import MongoClient
from pymongo import ASCENDING
import datetime

client = MongoClient()
db = client.DS_logs
log_collection = db.ds_jobLogEntry
log_collection.ensure_index([("timestamp", ASCENDING)])


def log(msg):
    entry = {}
    entry['timestamp'] = datetime.datetime.utcnow()
    entry['msg'] = msg
    log_collection.insert(entry)

def job_test():
    print ("Hello World")
    log('Job executed' + job_test)

jobstores = {
    'mongo': {'type': 'mongodb'},
}
executors = {
    'default': {'type': 'threadpool', 'max_workers': 20},
    'processpool': ProcessPoolExecutor(max_workers=5)
}

if __name__ == '__main__':
    scheduler = BackgroundScheduler()
    scheduler.configure(jobstores=jobstores, executors=executors, timezone=utc)
    scheduler.add_job(job_test, "interval", seconds=5, id='test_job')
    scheduler.start()

Ничего в журналах Монго(даже через час).Пожалуйста, обратитесь к снимку:

enter image description here

...