| 三层时区 | 调度系统时区、DAG/任务时区、数据存储时区 |
|---|---|
| Airflow | 要求 timezone-aware 的 start_date，建议显式指定 |
| 核对 | DAG 详情页显示的 Next Run 时间 |
Airflow 指定本地时区
Airflow 指定本地时区
import pendulum
from airflow import DAG
local_tz = pendulum.timezone('Asia/Shanghai')
dag = DAG(
'daily_orders',
start_date=pendulum.datetime(2026, 1, 1, tz=local_tz),
schedule='0 2 * * *', # 按 Asia/Shanghai 解释
catchup=False,
)服务器与数据库用 UTC、报表按北京时间解读时，查数要统一转换口径，避免“同一天数据少 8 小时”。