教程:在 Apache Airflow 作业中运行 Hello-world DAG

注意

Apache Airflow 作业由 Apache Airflow 提供支持。

在本教程中,将在 Apache Airflow 作业中运行 Hello-world DAG。 本教程着重于让用户熟悉 Apache Airflow 作业的功能和环境。

先决条件

若要开始,必须满足以下先决条件:

  • 在租户中启用 Apache Airflow 作业。

    注意

    由于 Apache Airflow 作业处于预览状态,因此需要通过租户管理员启用它。如果你已看到 Apache Airflow 作业,则租户管理员可能已启用它。

    1. 转到“管理门户”->“租户设置”-> 在 Microsoft Fabric 下 -> 展开“用户可以创建和使用 Apache Airflow 作业(预览版)”部分。

    2. 单击“应用”。

      在租户中启用 Apache Airflow 的屏幕截图。

创建 Apache Airflow 作业

  1. 可使用现有工作区或创建新工作区

  2. 展开 + New 下拉列表 -> 单击“更多选项” - Data Factory 部分下 > -> 选择 Apache Airflow 作业(预览版)

    屏幕截图显示点击更多选项。

    选择 Apache Airflow 作业的屏幕截图。

  3. 给项目起一个名字,然后点击“创建”按钮。

创建 DAG 文件

  1. 单击“新建 DAG 文件”卡片 - > 为文件命名,然后单击“创建”按钮。

    命名 DAG 文件的屏幕截图。

  2. 将向你显示样本 DAG 代码。 可根据要求编辑文件。

    显示了 Microsoft Fabric 中的样本 DAG 文件的屏幕截图。

  3. 单击“保存”图标。

    显示如何在 Microsoft Fabric 中保存 DAG 文件的屏幕截图。

在 Apache Airflow UI 中监视 Apache Airflow DAG

  1. 保存的 DAG 文件将加载到 Apache Airflow UI 中。 可以通过单击“Apache Airflow 中的监视器”按钮来监视它们。

    监视 Airflow DAG 的屏幕截图。

    屏幕截图显示了加载的 Airflow DAG。

快速入门:创建 Apache Airflow 作业