Azure ADF-如何仅在新文件到达后继续进行管道活动

Question

我已经使用databricks笔记本编写了通用的数据文件到达检查例程，该例程接受文件名，并指定可接受的文件新鲜度的时间。许多管道使用此笔记本并传递文件名元组，最后笔记本返回True或False，以指示下一个工作流活动是否可以启动。到目前为止还不错。现在我的问题是，如何在Azure ADF管道中使用它，这样，如果它失败了，它应该等待30分钟左右，然后通过再次在笔记本上运行来再次检查？这个笔记本应该先运行，这样如果新文件已经存在，就不应该等待

Answer 1

既然您谈论的是笔记本活动，那么您可以添加一个等待活动"故障时"；并设置等待时间。等待后添加一个executepielien activity。此执行管道应指向一个管道，其中执行管道(再次(指向具有笔记本活动的主管道。基本上，这只是一个循环，但只有在出现故障时才会执行。