왜 작동하지 않습니까? 이것은 apscheduler 버그입니까?

Question

이것을 실행하면 1 분 정도 기다렸다가 '켜짐'이 인쇄되고 2 분 정도 기다렸다가 '꺼짐'이 인쇄됩니다. 그 후에 apscheduler는 열매를 맺는 것처럼 보이고 빨리 2 개 사이에서 빨리 교체됩니다.

나는 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) 

한 번만 스케줄러를 시작해야합니다.