通过 Python 调度一个 Dag
您已经学会了不少关于创建 Dag 的知识，但现在您希望把某个 Dag 安排在每周的特定一天、特定时间运行。您还希望把这些信息写进代码里，以便同事需要把该 Dag 重新安装到不同服务器时能直接复用。
Airflow 的 dag 对象和相应的 datetime 方法已为您导入。
本练习是课程的一部分
Python 中的 Apache Airflow 入门
练习说明
- 将 Dag 的开始日期设置为 2025年11月1日。
- 使用 cron 语法将调度配置为每周三下午 12:30 运行。
交互式实操练习
通过完成这段示例代码来试试这个练习。
@dag(
dag_id='update_dataflows',
# Set to November 1, 2025
start_date=datetime(____),
# Every Wednesday at 12:30pm
schedule='____'
)
def update_dataflows():
@task
def pull_source_data():
pass
update_dataflows()