🔥 TIL - Day 28

프로젝트에서 매일 오전 9시에 발의법안 API로부터 받은 어제자 발의법안을 사용자에게 이메일로 전송하는 기능을 구현 중에 있었다.

현재 프로젝트에서 총 3개의 스케줄러를 사용하고 있는데 메일전송 스케줄러만 제대로 동작을 하지 않았다. 에러 로그를 보고 열심히 구글링 한 결과 쓰레드 관련 문제인 것 같은데 아직 Flask 에서 에러 로그를 보고 해결하는 실력이 부족해서 거의 포기상태였다..

일단 잔머리를 조금 굴려보기로 했다. 일단 결과부터 말하자면 잘 동작하도록 수정했다.

📌 Solution ...!

처음 오류를 발생시킨 접근방법은 APScheduler의 Job으로 메일을 전송하는 메서드를 그대로 넣은 방식이다. 사실 당연히 이렇게 해서 동작이 되어야 한다. 근데 일단 에러를 뱉어내니 다른 방버을 사용했다.

[ 첫번째, 에러를 발생시킨 방법 ]

from apscheduler.schedulers.background import BackgroundScheduler, BlockingScheduler
from apscheduler.triggers.cron import CronTrigger

def 메일보내기_메서드():
	...

cron = "분 시 * * *"

scheduler = BackgroundScheduler(daemon=True)
scheduler.add_job(메일보내기_메서드, CronTrigger.from_crontab(cron))
scheduler.start()

해결한 방식이다. 메일을 보내는 메서드를 API로 매핑시키고 스케줄러의 Job에서는 해당 API를 부르는 식으로 변경했다.

[ 두번째, 스케줄러 정상 동작 ]

@app.get('/api/mail')
def 메일보내기_메서드():
	...


def start_send_mail_job():
    print('알림 메일 전송 스케줄러 Start')
    requests.get('http://localhost:5000/api/mail')
    print('알림 메일 전송 스케줄러 End')
    return "ok"

cron = "13 14 * * *"

scheduler = BlockingScheduler(daemon=True)
scheduler.add_job(start_send_mail_job, CronTrigger.from_crontab(cron))
scheduler.start()

EC2에 스케줄러들을 몰아서 배포환경에서 사용 중인데 BackgroundScheduler 사용시 Job이 2번씩 수행되는 문제가 생겨서 BlockingScheduler로 변경했다.