Почему это не работает? Является ли это ошибкой apscheduler?

Question

Когда я запускаю это, он ждет минуту, затем он печатает «Загорается», затем ждет две минуты и печатает «Свет выключен». После этого apscheduler, кажется, сходит с ума и быстро чередует между двумя очень быстро.

Я только что наткнулся на ошибку apscheduler или почему это произошло?

from datetime import datetime, timedelta 
import time 
import os, signal, logging 
logging.basicConfig(level=logging.DEBUG) 

from apscheduler.schedulers.background import BackgroundScheduler 
scheduler = BackgroundScheduler() 


def turn_on(): 
    #Turn ON 
    print('##############################Lights on') 


def turn_off(): 
    #Turn off 
    print('#############################Lights off') 


def schedule(): 
    print('Lights will turn on at'.format(lights_on_time)) 
if __name__ == '__main__': 

    while True: 
     lights_on_time = (str(datetime.now() + timedelta(minutes=1))) 
     lights_off_time = (str(datetime.now() + timedelta(minutes=2))) 

     scheduler.add_job(turn_on, 'date', run_date=lights_on_time) 
     scheduler.add_job(turn_off, 'date', run_date=lights_off_time) 
     try: 
      scheduler.start() 
      signal.pause() 
     except: 
      pass 

    print('Press Ctrl+{0} to exit'.format('Break' if os.name == 'nt' else 'C')) 

    try: 
     # This is here to simulate application activity (which keeps the main thread alive). 
     while True: 
      time.sleep(2) 
    except (KeyboardInterrupt, SystemExit): 
     # Not strictly necessary if daemonic mode is enabled but should be done if possible 
     scheduler.shutdown() 

Answer 1

Вы наводняете планировщик событиями. Вы используете BackgroundScheduler, что означает, что scheduler.start() выходит и не ждет события. Самое простое исправление может состоять в том, чтобы не использовать BackgroundScheduler (используйте BlockingScheduler) или поставить sleep (180) в ваш цикл.

Answer 2

Попробуйте это:

from datetime import datetime, timedelta 
from apscheduler.schedulers.background import BackgroundScheduler 
import time 

scheduler = BackgroundScheduler() 


def turn_on(): 
    print('Turn on', datetime.now()) 


def turn_off(): 
    print('Turn off', datetime.now()) 


scheduler.start() 


while True: 
    scheduler.add_job(func=turn_on, trigger='date', next_run_time=datetime.now() + timedelta(minutes=1)) 
    scheduler.add_job(func=turn_off, trigger='date', next_run_time=datetime.now() + timedelta(minutes=2)) 
    time.sleep(180) 

Вы должны начать только планировщик один раз.