30분
콜백: Slack으로 알림 보내기
Day 4: 작업 실패하면 슬랙으로 알림 줘
콜백: Slack으로 알림 보내기
Apache Airflow - 워크플로우 오케스트레이션 > Day 4: 작업 실패하면 슬랙으로 알림 줘
학습 목표
콜백 함수를 정의할 수 있다 Slack Webhook으로 알림을 보낼 수 있다
콜백 종류
| 콜백 | 호출 시점 |
|---|---|
on_failure_callback | Task 실패 시 (재시도 소진 후) |
on_success_callback | Task 성공 시 |
on_retry_callback | 재시도 발생 시 |
sla_miss_callback | SLA 위반 시 |
콜백 함수 구조
에디터 로딩 중...
미션
Slack으로 실패 알림을 보내는 DAG를 구현하세요.
에디터 로딩 중...
힌트 보기
- • context 딕셔너리에 task, dag, logical_date 등이 담겨 있다
- • on_failure_callback은 재시도를 모두 소진한 후 호출된다
- • SlackWebhookHook 사용하려면 Connection 설정 필요
- • DAG 레벨 콜백은 @dag 데코레이터에 직접 설정
정답 보기
에디터 로딩 중...