如何在Azure Data Factory中实现源Blob Storage文件删除时自动清理目标Blob Storage中的对应文件？

嗨，我明白你遇到的问题啦——你用了ADF里那个仅按LastModifiedDate复制新文件的模板，单向同步Blob存储A到B，新文件同步得挺顺畅，但源A里删了文件，目标B里的对应文件却留着，想实现自动清理对吧？之前你找到的SQL场景的方案确实不适用文件存储，我来给你说说针对Blob Storage的具体实现方法：

核心思路 #

要实现这个需求，我们需要先对比源和目标的文件列表，找出目标中存在但源中已删除的文件，再批量删除这些冗余文件。可以在你现有的复制新文件的流水线后面，追加一套清理逻辑，形成完整的「新增同步+删除同步」流程。

具体步骤 #

1. 获取源Blob存储的所有文件路径

   • 添加一个Get Metadata活动，连接到源Blob存储的目标容器，勾选「递归」选项，获取子项（Child Items）的列表。
   • 把获取到的文件路径提取出来，存储到一个数组变量（比如sourceFilePaths）里，注意要统一路径格式（比如只保留容器下的相对路径，避免因为完整URL或容器名差异导致匹配失败）。

2. 获取目标Blob存储的所有文件路径

   • 同样添加一个Get Metadata活动，连接到目标Blob存储的对应容器，同样勾选「递归」获取子项列表。
   • 把目标文件的路径也提取到另一个数组变量（比如targetFilePaths），路径格式要和源保持完全一致。

3. 筛选出目标中的冗余文件

   • 添加一个Filter活动，输入选择目标文件列表（或targetFilePaths变量），设置过滤条件：当前文件的路径不在sourceFilePaths数组中。
   • 这个步骤会得到目标中所有源已删除的文件列表。

4. 批量删除冗余文件

   • 添加一个For Each活动，遍历上一步筛选出的冗余文件列表。
   • 在For Each循环内部，添加Delete活动，连接到目标Blob存储，指定要删除的文件路径（直接用循环中的当前项路径即可）。
   • 如果文件数量较多，可以适当调整For Each的并行度，平衡执行效率和ADF的限流规则。

注意事项 #

• 路径匹配是关键：一定要确保源和目标的文件路径格式完全一致，比如是否包含容器名称、是否使用相对路径，避免因为格式差异误删文件。
• 可以添加日志记录：在删除前后添加Set Variable或Web活动记录操作日志，方便后续排查问题。
• 测试验证：先在测试环境中验证逻辑，避免误删生产环境的重要文件。

备注：内容来源于stack exchange，提问作者Francesco Mantovani