happybell80
d424110726
- 사용자 요청 기반 알림 시스템 설계 - 일회성/반복/상대시간 알림 구현 방법 - rb8001 통합 방안 및 구현 우선순위 - 크론잡 대비 장점과 주의사항 정리
271 lines
7.1 KiB
Markdown
271 lines
7.1 KiB
Markdown
# 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 도입 시 더 유연한 스케줄링이 가능할 것으로 예상. 특히 사용자 개별 요청 기반 알림은 크론으로는 구현이 어려워 이 방식이 적합함. |