创建一个简单的 Dag
您已经花时间回顾了 Airflow 的各个组件，现在想要亲自测试一下自己的工作流。首先，您决定先定义默认参数，并为工作流创建一个 Dag 对象。
已为您导入了 datetime 对象。
本练习是课程的一部分
Python 中的 Apache Airflow 入门
练习说明
- 导入 Airflow 的 Dag 对象；注意大小写敏感。
- 定义 Dag 装饰器，并将 Dag 命名为
example_etl。 - 在代码文件末尾运行该 Dag 函数。
交互式实操练习
通过完成这段示例代码来试试这个练习。
# Import the dag object
from ____ import dag
# Define the Dag attributes
____(
____='example_etl',
start_date=datetime(2026, 3, 1),
)
def example_etl():
pass
# Run the Dag
____()