如何在Azure Data Factory V2中设置仅当前执行完成时触发管道？

当然可以实现！要让Azure Data Factory（ADF）里的管道持续运行，且仅当没有正在运行的实例时才启动下一次，你可以通过几种实用方案来达成，我给你拆解下最常用的两种：

这个方案完全依赖ADF自身组件，不需要额外部署其他服务，适合快速落地：

• 第一步：拆分管道结构
  把你的业务逻辑放到一个主管道（比如命名为Main_Processing_Pipeline）里，另外创建一个控制管道（比如Orchestrator_Pipeline）负责调度逻辑。
• 第二步：在控制管道里添加状态检查
  1. 加入一个Web活动，调用ADF的Get Pipeline Runs REST API，用来查询主管道的运行状态：
     • 请求URL：https://management.azure.com/subscriptions/{你的订阅ID}/resourceGroups/{资源组名}/providers/Microsoft.DataFactory/factories/{数据工厂名}/pipelineruns?api-version=2018-06-01
     • 请求方法：GET
     • 添加查询参数$filter，值为PipelineName eq 'Main_Processing_Pipeline' and Status eq 'InProgress'（只筛选正在运行的实例）
     • 身份验证选择托管标识，确保数据工厂的托管标识有Data Factory Contributor权限
  2. 加入一个If Condition活动，判断Web活动返回的value数组是否为空：
     • 条件表达式：empty(activity('Web_Get_Running_Pipelines').output.value)
     • 如果条件为真（没有正在运行的实例），就添加一个Execute Pipeline活动，启动Main_Processing_Pipeline；如果为假，直接结束控制管道即可
• 第三步：给控制管道设置递归触发器
  给Orchestrator_Pipeline添加一个递归触发器，设置一个合理的轮询间隔（比如1分钟）。这样控制管道会定期检查主管道状态，只要主管道完成（无论成功或失败），就会在下一次轮询时启动新的实例。

如果不想用轮询，而是希望主管道一完成就立刻启动下一次，可以结合逻辑应用实现事件驱动，响应更及时：

• 第一步：创建逻辑应用并配置触发器
  新建一个逻辑应用，选择Azure Data Factory - 当管道运行完成时作为触发器，指定你的数据工厂和Main_Processing_Pipeline，这样不管主管道是成功还是失败，都会触发逻辑应用。
• 第二步：添加管道状态检查步骤
  在逻辑应用里添加一个HTTP动作，调用ADF的Get Pipeline Runs API（和方案1里的API一致），筛选InProgress状态的主管道实例。
• 第三步：启动新的管道实例
  添加一个条件判断，如果HTTP动作返回的value数组为空，就调用ADF的Create Pipeline Run API，启动Main_Processing_Pipeline。

• 务必检查InProgress状态：不管用哪种方案，这一步是核心，避免同一管道同时运行多个实例，防止数据冲突或资源过载。
• 权限配置：确保调用ADF API的身份（托管标识或服务主体）拥有足够的权限，至少需要Data Factory Contributor角色来查询和启动管道。
• 限流问题：如果用轮询方案，间隔不要设置得太短（比如不要低于30秒），避免触发ADF的API调用配额限制。

内容的提问来源于stack exchange，提问作者Ryan Papke