Airflow技术问询：如何按英国时区特定时间每日多次调度DAG

架构老林

2026-5-8

解决Airflow英国时区调度与start_date的困惑

我来帮你拆解一下你遇到的Airflow调度问题——核心是对Airflow的调度逻辑理解有偏差，再加上start_date配置和时区处理的细节没踩对。下面一步步帮你解决：

一、先搞懂Airflow调度的核心逻辑

首先得明确一个很多人踩坑的点：Airflow调度器是在「调度周期结束时」触发任务的，而不是你想的“到点就跑”。比如你设置的6小时15分钟间隔，每个任务触发时，对应的是前一个6h15m周期的结束时间，而任务的execution_date（执行日期）是这个周期的开始时间。

举个你例子里的场景：如果你的第一个周期是2020-07-29 19:15:00（英国时间）到2020-07-30 01:30:00，调度器会在01:30这个时间点触发任务，而任务的execution_date会显示为2020-07-29 19:15:00——这就是你看到界面上start_date显示异常的原因，Airflow是基于周期结束时间来计算触发时机的，不是直接用你设置的start_date。

二、正确配置英国时区的调度（适配夏令时）

你的需求是英国时间1:30、7:45、14:00固定间隔运行，还要适配夏令时（BST/GMT切换）。这里推荐两种方案，根据你的需求选择：

方案1：用timedelta实现严格6h15m间隔（适配时区）

如果你要严格保持6小时15分钟的间隔运行，用timedelta是可行的，但要注意两个关键细节：

绝对不要用动态start_date：你之前用datetime.now()生成start_date，这会导致每次DAG重新解析时start_date都变化，调度器根本无法正确追踪哪些周期需要运行，这是你catchup没生效的核心原因之一。
正确设置start_date和DAG时区：

修改后的代码如下：

import pendulum
from datetime import datetime, timedelta
from airflow import DAG
from airflow.operators.dummy import DummyOperator

# 固定英国时区
dag_timezone = pendulum.timezone("Europe/London")

# 设置一个固定的历史start_date，比如2024-01-01 01:30（英国时间），然后减去一个间隔
# 这样第一个调度周期的开始时间是2023-12-31 19:15，结束时间是2024-01-01 01:30
# 调度器会在2024-01-01 01:30触发第一个任务
start_date = dag_timezone.datetime(2024, 1, 1, 1, 30, 0) - timedelta(hours=6, minutes=15)

with DAG(
    dag_id="uk_interval_dag",
    schedule_interval=timedelta(hours=6, minutes=15),
    start_date=start_date,
    catchup=True,
    timezone=dag_timezone,  # 关键！Airflow 2.0+支持这个参数，自动适配夏令时
    default_args={"owner": "Tom"}
) as dag:
    # 这里定义你的任务，比如：
    dummy_task = DummyOperator(task_id="dummy_task")

为什么要减去一个间隔？因为：

start_date是第一个调度周期的开始时间
调度周期是start_date → start_date + schedule_interval
调度器会在start_date + schedule_interval时触发任务，任务的execution_date就是start_date

这样设置后，调度器会严格按照英国时间的6h15m间隔触发，并且自动处理夏令时和冬令时的时区偏移变化。

方案2：用cron表达式精准匹配固定时间点

如果你只需要在1:30、7:45、14:00这三个固定时间运行（不考虑后续的20:15等时间点），可以直接用cron表达式配合时区设置：

import pendulum
from airflow import DAG
from airflow.operators.dummy import DummyOperator

dag_timezone = pendulum.timezone("Europe/London")

with DAG(
    dag_id="uk_fixed_time_dag",
    # cron格式：分钟 小时 日 月 星期，同时匹配三个时间点
    schedule_interval="30 1,45 7,0 14 * * *"  # 对应1:30、7:45、14:00
    start_date=dag_timezone.datetime(2024, 1, 1),
    catchup=True,
    timezone=dag_timezone,
    default_args={"owner": "Tom"}
) as dag:
    dummy_task = DummyOperator(task_id="dummy_task")

三、解决catchup未触发预期任务的问题

你设置了catchup=True但没看到今日的1:30和7:45任务运行，大概率是因为之前的动态start_date导致调度器无法确定需要补跑的周期。改用固定start_date后，catchup=True会自动补跑从start_date到当前时间之间所有未执行的周期。

另外可以检查这几点：

确保Airflow调度器所在服务器的时间是准确的，时区配置正常
去Airflow UI的「Browse → Task Instances」查看是否有任务实例处于排队、失败或跳过状态
检查DAG是否被启用（UI里DAG的开关是打开的）

四、调度器的调试模式

要查看调度器的运行逻辑，有几种实用方式：

开启调试日志：
- 修改airflow.cfg配置文件，设置scheduler_logging_level = DEBUG
- 或者启动调度器时直接指定日志级别：
```
airflow scheduler --log-level DEBUG
```
查看调度器日志：
默认日志存放在$AIRFLOW_HOME/logs/scheduler目录下，你可以看到调度器如何解析DAG、计算每个周期的触发时间、判断是否需要触发任务的详细过程。
UI辅助调试：
在Airflow UI的「Tree View」或「Graph View」里，可以直观看到每个任务的execution_date和实际触发时间，帮助你理解调度逻辑；「Browse → Dag Runs」可以查看所有DAG运行实例的时间信息。

内容的提问来源于stack exchange，提问作者Tom Lous

Airflow技术问询：如何按英国时区特定时间每日多次调度DAG

一、先搞懂Airflow调度的核心逻辑 #

二、正确配置英国时区的调度（适配夏令时） #

方案1：用timedelta实现严格6h15m间隔（适配时区） #

方案2：用cron表达式精准匹配固定时间点 #

三、解决catchup未触发预期任务的问题 #