Блог

Я использую apscheduler для выполнения задания cron, теперь я хочу, чтобы работа выполнялась каждые 1 минуту. Это мой код:

 # -*- coding: utf-8 -*-
import time

from apscheduler.schedulers.background import BackgroundScheduler
from apscheduler.triggers.interval import IntervalTrigger


if __name__ == '__main__':
    scheduler = BackgroundScheduler()
    scheduler.start()
    try:
        while True:
            time.sleep(2)
    except (KeyboardInterrupt, SystemExit):
        scheduler.shutdown()


@scheduler.scheduled_job(IntervalTrigger(seconds=60))
def func_to_be_executed():
    print("I am running......")
  

Но задание выполняется только один раз, что я должен сделать, чтобы оно выполнялось каждую минуту с помощью cron?

Попробуйте использовать подход декоратора. Это должно сработать.

 from apscheduler.schedulers.background import BackgroundScheduler
from apscheduler.triggers.interval import IntervalTrigger

scheduler = BackgroundScheduler()
scheduler.start()

@scheduler.scheduled_job(IntervalTrigger(seconds=60))
def func_to_be_executed():
  pass
  

Код для BlockingSchedular — используйте, когда планировщик — единственное, что работает в вашем процессе

 from apscheduler.schedulers.blocking import BlockingScheduler
from apscheduler.triggers.interval import IntervalTrigger

sched = BlockingScheduler()

@sched.scheduled_job(IntervalTrigger(seconds=10))
def timed_job():
    print('This job is run every 10 seconds.')

sched.start()