如何在Azure Data Factory中基于SQL表数据循环调用参数化API链接服务

我有一个通过复制数据活动（Copy Data Activity）从API链接服务拉取数据并插入SQL表的Azure Data Factory管道作业。API的基础URL为：https://api.test.com/v3/contacts/14299157/contactStats?startDate=2022-10-01&endDate=2022-11-03。我有如下结构的SQL表：

ContactID              StartDate              EndDate
     1                  01-jan-2020           01-jan-2021
     1                  01-jan-2022           01-jan-2023

我希望基于该SQL表的每行数据循环调用API，例如第一行对应调用URL：https://api.test.com/v3/contacts/1/contactStats?startDate=2020-01-01&endDate=2021-01-01，并将返回数据插入目标表；接着处理下一行，直到完成所有行的处理。请问该需求是否可行？应如何配置实现？

该需求完全可行，可通过Azure Data Factory（ADF）的Lookup活动+ForEach活动+复制数据活动组合实现，具体配置步骤如下：

1. 用Lookup活动读取SQL表的所有行数据 #

• 在ADF管道中添加Lookup活动，数据源选择存储ContactID/StartDate/EndDate的SQL表链接服务。
• 在Lookup活动的设置面板中，取消勾选"First row only"选项，确保读取表内全部行数据，作为后续循环的输入源。

2. 配置ForEach活动遍历每行数据 #

• 添加ForEach活动，将其Items属性设置为动态表达式：@activity('你的Lookup活动名称').output.value，实现对Lookup返回的每一行数据的遍历。
• 若API存在调用频率限制，建议开启ForEach的Sequential（顺序执行）选项；无限制则可保持并行执行以提升效率。

3. 在ForEach内部配置动态API调用的复制数据活动 #

• 在ForEach活动内部添加复制数据活动：
  • 源数据集：选择已配置好的API链接服务，在数据集的相对URL/查询参数中使用动态内容替换变量，构造符合要求的API请求地址，示例表达式如下：

    @concat('https://api.test.com/v3/contacts/', item().ContactID, '/contactStats?startDate=', formatDateTime(item().StartDate, 'yyyy-MM-dd'), '&endDate=', formatDateTime(item().EndDate, 'yyyy-MM-dd'))
    

    注：若SQL表中的日期格式无法直接被API识别，需通过formatDateTime等函数转换为API要求的yyyy-MM-dd格式。
  • 目标数据集：选择要插入数据的SQL目标表链接服务，完成字段映射规则配置即可。

4. 可选：添加异常处理机制 #

• 可为复制数据活动配置重试策略，应对API临时不可用的情况；也可在ForEach内部添加If Condition活动，单独处理异常行，避免单个行处理失败导致整个管道终止。

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