diff --git a/ideas/250905_APScheduler_PostgreSQL_alarm_system.md b/ideas/250905_APScheduler_PostgreSQL_alarm_system.md new file mode 100644 index 0000000..f9e097e --- /dev/null +++ b/ideas/250905_APScheduler_PostgreSQL_alarm_system.md @@ -0,0 +1,271 @@ +# APScheduler + PostgreSQL 조합으로 알림 시스템 구현 + +## 작성일: 2025-09-05 +## 작성자: admin +## 상태: 💡 아이디어 +## 목적: rb8001이 사용자 요청 기반 알림/스케줄 관리 + +--- + +## 1. 개요 + +사용자가 "내일 9시에 알려줘", "회의 30분 전 알림" 같은 요청을 하면, rb8001이 정확한 시간에 실행할 수 있는 시스템 구현. + +### 핵심 개념 +- **크론잡 한계**: 최소 1분 단위, 일회성 작업 비효율적 +- **APScheduler**: Python 기반 작업 스케줄러, 초 단위 정확도 +- **PostgreSQL JobStore**: 스케줄 영속성 보장, 서버 재시작 시에도 유지 + +--- + +## 2. 기본 구조 + +### 2.1 초기 설정 +```python +from apscheduler.schedulers.asyncio import AsyncIOScheduler +from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore + +# PostgreSQL을 JobStore로 사용 +jobstores = { + 'default': SQLAlchemyJobStore(url='postgresql://robeings:pass@localhost/main_db') +} + +# 스케줄러 생성 +scheduler = AsyncIOScheduler( + jobstores=jobstores, + timezone='Asia/Seoul' # KST 설정 +) +``` + +### 2.2 자동 생성 테이블 +```sql +-- APScheduler가 자동으로 생성하는 테이블 +CREATE TABLE apscheduler_jobs ( + id VARCHAR(191) PRIMARY KEY, + next_run_time FLOAT, + job_state BYTEA -- pickle 형태로 저장된 job 정보 +); +``` + +--- + +## 3. 주요 기능 구현 + +### 3.1 일회성 알림 +```python +async def handle_alarm_request(message: str, user_id: str): + """사용자: '내일 9시에 알려줘'""" + + # 자연어 시간 파싱 + run_time = parse_time(message) # → datetime(2025, 9, 6, 9, 0, 0) + + # 스케줄 등록 + scheduler.add_job( + func=send_slack_message, + trigger='date', # 일회성 트리거 + run_date=run_time, + args=[user_id, "요청하신 알림입니다"], + id=f"alarm_{user_id}_{timestamp}", + replace_existing=True + ) + + return f"네, {run_time.strftime('%m월 %d일 %H시 %M분')}에 알려드릴게요" +``` + +### 3.2 반복 알림 +```python +# 매일 오전 9시 브리핑 +scheduler.add_job( + func=daily_briefing, + trigger='cron', + hour=9, + minute=0, + args=[user_id], + id=f"daily_briefing_{user_id}" +) + +# 30분마다 상태 체크 +scheduler.add_job( + func=check_status, + trigger='interval', + minutes=30, + args=[user_id] +) +``` + +### 3.3 상대 시간 알림 +```python +async def set_reminder(hours_later: int, user_id: str, message: str): + """사용자: '3시간 후 다시 알려줘'""" + + run_time = datetime.now() + timedelta(hours=hours_later) + + scheduler.add_job( + func=send_reminder, + trigger='date', + run_date=run_time, + kwargs={'user_id': user_id, 'message': message} + ) +``` + +--- + +## 4. rb8001 통합 방안 + +### 4.1 의도 분석 확장 +```python +# rb8001/app/intent_analyzer.py +def analyze_schedule_intent(message: str): + patterns = { + r"(\d+)시간 후": "hours_later", + r"내일 (\d+)시": "tomorrow_at", + r"(\d+)분 전": "minutes_before", + r"매일|매주|매월": "recurring" + } + # 패턴 매칭으로 스케줄 타입 결정 +``` + +### 4.2 Slack 명령어 +```python +@app.message(re.compile(r"알려줘|알림|리마인더")) +async def handle_reminder(message, say): + # 메시지 파싱 + schedule_type, run_time = parse_schedule(message['text']) + + # APScheduler 등록 + job = scheduler.add_job(...) + + # 사용자 응답 + await say(f"✅ 알림이 설정되었습니다: {job.id}") +``` + +--- + +## 5. 알림 관리 기능 + +### 5.1 알림 조회 +```python +def get_user_alarms(user_id: str): + """내 알림 목록 보기""" + jobs = scheduler.get_jobs() + user_jobs = [job for job in jobs if user_id in job.id] + + return [{ + 'id': job.id, + 'next_run': job.next_run_time, + 'name': job.name + } for job in user_jobs] +``` + +### 5.2 알림 취소 +```python +def cancel_alarm(job_id: str): + """알림 취소""" + try: + scheduler.remove_job(job_id) + return "알림이 취소되었습니다" + except JobLookupError: + return "해당 알림을 찾을 수 없습니다" +``` + +### 5.3 알림 수정 +```python +def modify_alarm(job_id: str, new_time: datetime): + """알림 시간 변경""" + scheduler.reschedule_job( + job_id, + trigger='date', + run_date=new_time + ) +``` + +--- + +## 6. 트리거 타입별 사용 예시 + +| 트리거 | 사용 사례 | 예시 | +|--------|-----------|------| +| date | 일회성 알림 | "내일 3시 회의 알려줘" | +| interval | 정기 체크 | "30분마다 서버 상태 확인" | +| cron | 정기 작업 | "매주 월요일 9시 주간 리포트" | + +--- + +## 7. 구현 시 고려사항 + +### 7.1 장점 +- ✅ 초 단위 정확도 +- ✅ 서버 재시작 시 자동 복구 +- ✅ 다양한 스케줄 패턴 지원 +- ✅ PostgreSQL 통합으로 별도 인프라 불필요 + +### 7.2 주의점 +- ⚠️ job_state가 pickle이므로 함수 시그니처 변경 시 주의 +- ⚠️ 대량 작업 시 메모리 사용량 모니터링 필요 +- ⚠️ timezone 설정 필수 (KST) +- ⚠️ 실패한 작업 재시도 로직 구현 필요 + +### 7.3 제한사항 +- 분산 환경에서는 별도 고려 필요 +- 매우 정밀한 시간(밀리초)은 지원 안됨 + +--- + +## 8. 대안 기술 스택 + +| 기술 | 장점 | 단점 | +|------|------|------| +| Celery + Redis | 분산 처리, 확장성 | 복잡한 설정 | +| AWS EventBridge | 관리형 서비스 | 비용, 외부 의존성 | +| Kubernetes CronJob | 컨테이너 네이티브 | k8s 필요 | +| systemd timer | OS 레벨 통합 | 프로그래밍 어려움 | + +--- + +## 9. 구현 우선순위 + +1. **Phase 1**: 일회성 알림 (date trigger) + - "N시간 후 알려줘" + - "내일 오전 9시 알림" + +2. **Phase 2**: 반복 알림 (cron trigger) + - "매일 아침 브리핑" + - "매주 월요일 리포트" + +3. **Phase 3**: 고급 기능 + - 알림 수정/취소 + - 알림 목록 조회 + - 실패 재시도 + +--- + +## 10. 예상 사용 시나리오 + +``` +사용자: "내일 오후 2시 클라이언트 미팅 있다고 30분 전에 알려줘" +rb8001: "네, 내일 오후 1시 30분에 미팅 알림 드릴게요 📅" + +사용자: "매주 금요일마다 주간 보고서 작성하라고 알려줘" +rb8001: "매주 금요일 알림을 설정했습니다 📝" + +사용자: "내 알림 목록 보여줘" +rb8001: + • 내일 13:30 - 클라이언트 미팅 알림 + • 매주 금요일 09:00 - 주간 보고서 작성 + • 매일 09:00 - 일일 브리핑 + +사용자: "미팅 알림 취소해줘" +rb8001: "미팅 알림이 취소되었습니다" +``` + +--- + +## 11. 참고 자료 + +- [APScheduler 공식 문서](https://apscheduler.readthedocs.io/) +- [PostgreSQL JobStore 설정](https://apscheduler.readthedocs.io/en/stable/modules/jobstores/sqlalchemy.html) +- 기존 크론 시스템: `/home/admin/DOCS/troubleshooting/250824_rb8001_daily_summary_cron_failure.md` + +--- + +**작성자 메모**: 현재 rb8001은 Gateway 크론에 의존하고 있으나, APScheduler 도입 시 더 유연한 스케줄링이 가능할 것으로 예상. 특히 사용자 개별 요청 기반 알림은 크론으로는 구현이 어려워 이 방식이 적합함. \ No newline at end of file