2017-11-02 8 views
0
from apscheduler.schedulers.blocking import BlockingScheduler 
from apscheduler.triggers.cron import CronTrigger 


def p(): 
    print("a") 

if __name__ == '__main__': 
    scheduler = BlockingScheduler() 
    trigger = CronTrigger(second='1/5') 
    scheduler.add_job(p, trigger) 

    try: 
     scheduler.start() 
    except Exception as e: 
     pass 

このコードをapscheduler.schedulers.blockingという名前のモジュール、私はテストのためにこれをUESませんが、このようなエラーが表示さ:なぜ使用apscheduler:インターネットから

をapscheduler.schedulers.blockingという名前のモジュール

でもあります彼らはすべてのunpassであり、私はapscheduler 3.4.0を使用しますが、3.0.1を使用して2.xxのは、私は多くの問題を発見していない、あまりにもunpassでテスト

from datetime import datetime 
import os 

from apscheduler.scheduler import BlockingScheduler 


def tick(): 
print('Tick! The time is: %s' % datetime.now()) 


if __name__ == '__main__': 
scheduler = BlockingScheduler() 
scheduler.add_job(tick, 'interval', seconds=3) 
print('Press Ctrl+{0} to exit'.format('Break' if os.name == 'nt' else 'C'$ 

try: 
    scheduler.start() 
except (KeyboardInterrupt, SystemExit): 
    pass 

from apscheduler.schedulers.background import BackgroundScheduler 


# The "apscheduler." prefix is hard coded 
scheduler = BackgroundScheduler({ 
    'apscheduler.jobstores.mongo': { 
     'type': 'mongodb' 
    }, 
    'apscheduler.jobstores.default': { 
     'type': 'sqlalchemy', 
     'url': 'sqlite:///jobs.sqlite' 
    }, 
    'apscheduler.executors.default': { 
     'class': 'apscheduler.executors.pool:ThreadPoolExecutor', 
     'max_workers': '20' 
    }, 
    'apscheduler.executors.processpool': { 
     'type': 'processpool', 
     'max_workers': '5' 
    }, 
    'apscheduler.job_defaults.coalesce': 'false', 
    'apscheduler.job_defaults.max_instances': '3', 
    'apscheduler.timezone': 'UTC', 
}) 

import os ,subprocess 
from APScheduler.schedulers.blocking import BlockingScheduler 



def scheduled_job(): 
    sync_to_drive=subprocess.check_output(["./gdrive", "sync", "upload", "--keep-local", "/home/pi/Documents"], cwd="/home/pi/Downloads") 
    print (sync_to_drive) 

sched = BlockingScheduler() 
sched.add_job(scheduled_job, "interval", seconds=5) 
sched.start() 

ために他のコードを使用します任意の解決策、私を助けてください...

そして私はあなたのスパイダーがmongoDBにデータを取得できるようにするためにapschedulerを使います

答えて

関連する問題