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を使います