你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

使用 Azure Blob 存储导入 DAG

注释

此功能目前为公共预览版。 工作流业务流程管理器由 Apache Airflow 提供支持。

本文介绍了如何使用 Azure Blob 存储将定向无环图(DAG)导入工作流业务流程管理器的分步说明。

先决条件

预览版期间不支持虚拟网络后面的 Blob 存储。 在 storageLinkedServices 中的 Azure Key Vault 配置不支持导入 DAG。

导入 DAG

  1. 根据您设置的 Airflow 环境,复制示例 Apache Airflow v2.x DAG示例 Apache Airflow v1.10 DAG。 将内容粘贴到名为 tutorial.py 的新文件中。

    tutorial.py 文件上传到 Blob 存储。 有关详细信息,请参阅 将文件上传到 Blob

    注释

    需要从 Blob 存储帐户中选择一个目录路径,其中包含名为 dag 和插件的文件夹,以将其导入 Airflow 环境。 插件不是必需的。 还可以有一个名为 dag 的 容器,并上传其中的所有 Airflow 文件。

  2. “管理中心 ”下,选择 “Apache Airflow”。 然后将鼠标悬停在之前创建的 Airflow 环境上,然后选择 “导入文件 ”,将所有 DAG 和依赖项导入 Airflow 环境。

    显示在管理中心导入文件的屏幕截图。

  3. 创建指向“先决条件”部分中提到的可访问存储帐户的新链接服务。 如果已有自己的 DAG,也可以使用现有 DAG。

    显示如何创建新的链接服务的屏幕截图。

  4. 使用您上传 DAG 的存储帐户。 (检查“先决条件”部分)。测试连接,然后选择“ 创建”。

    显示一些链接服务详细信息的屏幕截图。

  5. 如果使用示例 SAS URL,请浏览并选择 airflow 。 还可以选择包含 DAG 文件的 dags 文件夹所在的文件夹

    注释

    可以通过此接口导入 DAG 及其依赖项。 需要从 Blob 存储帐户中选择一个目录路径,其中包含名为 dag 和插件的文件夹,以将其导入 Airflow 环境。 插件不是必需的。

    显示“导入文件”屏幕上的“浏览存储”按钮的屏幕截图。

    屏幕截图显示“浏览”上的 airflow 根文件夹。

  6. 选择 “导入 ”以导入文件。

    显示“导入文件”屏幕上的“导入”按钮的屏幕截图。

    显示导入 DAG 的屏幕截图。

在预览期间,导入 DAG 可能需要几分钟时间。 可以使用通知中心(数据工厂 UI 中的钟形图标)跟踪导入状态更新。