Airflow DAGs

在 Airflow 中，流水线用有向无环图（Directed Acyclic Graph，简称 DAG）表示。图中的节点代表要执行的任务，节点之间的有向连接表示任务之间的依赖关系。

将数据流水线表示为 DAG 很合理，因为有些任务必须先完成，其他任务才能开始。您可以把它类比为汽车工厂的装配线。任务逐步叠加，每个任务都可能依赖于之前任务的完成。一个虚构的 DAG 可能如下所示：

Example DAG

首先组装车架，然后是车身和轮胎，最后进行喷漆。让我们在代码中复现上面的示例。

本练习是课程的一部分

Data Engineering 入门

查看课程

交互式实操练习

通过完成这段示例代码来试试这个练习。

# Create the DAG
@dag(dag_id="car_factory_simulation",
     start_date=datetime(2024, 1, 1),
     schedule="____")
def car_factory_simulation():
    pass

# Run the DAG
car_factory_simulation()

编辑并运行代码