You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

如何在Azure Data Factory中获取通配符路径下的已复制文件列表?

获取Azure Data Factory中复制的文件名并发送通知邮件

方法一:通过Get Metadata + 变量收集文件名

适合文件数量不多的场景:

  • 添加Get Metadata活动:配置与Copy Activity相同的源数据集(使用通配符路径),在字段选项中勾选Child Items,获取所有匹配通配符的文件列表。
  • 初始化字符串变量:创建名为copiedFileList的变量,初始值设为空字符串。
  • 添加ForEach活动:遍历Get Metadata的输出结果,遍历表达式为@activity('Get Metadata活动名称').output.childItems。
  • 在ForEach内添加Set Variable活动:将当前遍历到的文件名追加到变量中,示例表达式:
    @concat(variables('copiedFileList'), item().name, '\n')
    
    (用换行符分隔,方便邮件内换行显示)
  • 发送邮件:在Send Email活动的内容中引用变量@variables('copiedFileList'),即可展示所有已复制文件名。

方法二:通过Copy Activity日志提取文件名

适合文件数量较多或需要保留复制记录的场景:

  • 启用Copy Activity日志:在Copy Activity的设置标签页,找到日志存储,指定存储账户、容器和路径前缀,日志会自动记录每个复制文件的详细信息(含源文件名)。
  • 读取日志文件:复制完成后,用Lookup活动读取生成的日志CSV文件,配置数据集指向日志存储路径,筛选出SourceFileName列。
  • 整理文件名:将Lookup返回的结果转换为字符串列表,示例表达式:
    @join(activity('Lookup活动名称').output.value, '\n')
    
  • 嵌入邮件内容:将整理后的字符串插入到Send Email的内容中。

方法三:通过Azure Function辅助处理

适合需要自定义文件筛选或复杂逻辑的场景:

  • 创建Azure Function:编写函数接收通配符路径参数,调用存储SDK列出所有匹配的文件,返回文件名列表。
  • 在ADF中调用Function:添加Azure Function活动,传入源路径参数,获取返回的文件名列表。
  • 传递到邮件:将Function的输出结果直接用到Send Email活动的内容中。

注意事项

  • 如果Copy Activity设置了文件过滤条件(如按修改时间),需确保Get Metadata或Function的逻辑同步该过滤,避免获取未复制的文件。
  • 若文件数量极大,变量存储可能超出长度限制,优先选择日志方法或生成文件后邮件附链接的方式。

内容的提问来源于stack exchange,提问作者Duc Vu

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.06.30 21:22:45