如何让Tumbling Window Trigger重试时获取Storage Event触发失败的Blob文件名？

针对你描述的场景——存储事件触发器触发ADF管道处理Blob，失败后用翻滚窗口触发器重试，且重试时需获取失败的Blob文件名，可按以下步骤实现：

现有配置回顾 #

• 存储事件触发器：通过triggerBody().fileName将Blob文件名传递至管道参数
• 翻滚窗口触发器：配置3次重试、间隔30秒， recurrence为5分钟，作为失败重试机制
• 管道内通过Set Variable + Fail活动模拟失败场景

具体实现步骤 #

1. 持久化失败Blob的关键信息 #

在管道的Fail活动执行前，添加一个数据写入活动（比如Copy Data或Azure Function），把当前要处理的Blob文件名、触发时间、重试次数初始值（0）存储到外部存储介质中：

• 推荐用Azure Table Storage：创建一张重试记录表，用触发器触发时间作为分区键，Blob文件名作为行键，额外添加RetryCount（初始0）、Status（标记为"Failed"）字段
• 也可以用Blob存储：写入一个JSON格式的重试队列文件，每条记录包含上述信息

2. 让翻滚窗口触发器读取失败记录 #

修改翻滚窗口触发的管道逻辑，在开头添加Lookup活动：

• 配置Lookup活动读取第一步创建的重试记录表/队列Blob，筛选出RetryCount < 3且触发时间落在当前翻滚窗口时间范围内的记录
• 将管道的文件名参数赋值为@activity('Lookup失败记录').output.firstRow.FileName，确保重试时能拿到目标Blob文件名

3. 更新重试状态与计数 #

• 若管道执行成功：添加Delete或Update活动，删除对应的重试记录，或把Status更新为"Succeeded"
• 若管道执行失败：添加Update活动，将该记录的RetryCount加1，确保后续翻滚窗口触发时仍能读取到该记录（直到重试次数达3次上限）

4. 优化翻滚窗口触发逻辑（可选） #

给翻滚窗口触发器添加触发条件，避免空跑：

• 在触发器的动态内容中设置触发条件为@greater(activity('Lookup失败记录').output.count, 0)，只有当存在未处理的失败记录时才触发管道

注意事项 #

• 确保ADF对存储重试记录的介质有读写权限，避免权限问题导致重试逻辑失效
• 翻滚窗口的时间粒度（5分钟）要和事件触发器的触发时间范围匹配，保证能准确筛选到对应时间的失败记录
• 正式环境可移除模拟失败的Fail活动，替换为实际业务流程中的失败判断逻辑

内容的提问来源于stack exchange，提问作者Shripad Daware