| 重试参数 | retries、retry_delay、重试间隔退避 |
|---|---|
| 告警 | 失败告警、超时告警、连续失败升级 |
| 上下文 | DAG/任务名、业务日期、执行实例链接 |
Airflow default_args 示例
Airflow default_args 示例
from datetime import timedelta
default_args = {
'retries': 3,
'retry_delay': timedelta(minutes=5),
'email_on_failure': True,
'email': ['data-oncall@example.com'],
}
dag = DAG('daily_orders', default_args=default_args, schedule='0 2 * * *')重试次数乘以间隔会决定最晚告警时间：3 次 ×5 分钟意味着故障要 15 分钟后才彻底暴露。