我试图重现这个问题,它对我来说工作正常。请在创建管道时检查以下几点。
- 检查您是否在 main.py 文件的第 6 行粘贴了存储帐户连接字符串
- 您需要在 Azure 数据工厂 (ADF) 中创建 Blob 存储和批处理链接服务。配置 ADF 管道时,“Azure Batch”和“设置”选项卡中将需要这些链接服务。请按照以下快照创建链接服务。
在 ADF 门户中,单击左侧的“管理”符号,然后单击 +新建以创建 Blob 存储链接服务。

搜索“Azure Blob 存储”,然后单击“继续”

根据您的存储帐户填写所需的详细信息,测试连接,然后单击应用。

同样,搜索 Azure Batch 链接服务(在计算选项卡下)。

填写您的批处理帐户的详细信息,使用之前在“存储链接服务名称”下创建的存储链接服务,然后测试连接。点击保存。

稍后,当您将创建自定义 ADF 管道时,在“Azure Batch”选项卡下,提供 Batch Linked Service Name。

在“设置”选项卡下,提供存储链接服务名称和其他所需信息。在“文件夹路径”中,提供具有 main.py 和 iris.csv 文件的 Blob 名称。

完成此操作后,您可以验证、调试、发布和触发管道。管道应该成功运行。

管道成功运行后,您将在输出 Blob 中看到 iris_setosa.csv 文件。
