如何将SQL查询结果作为数组传入Azure Data Factory的Foreach循环

问题分析 #

当前你通过SQL查询获取用户ID后，无法直接转换成ADF Foreach循环可识别的数组：

• 用STRING_AGG拼接成JSON格式字符串，ADF仅识别为字符串而非数组
• 直接将Lookup结果赋值变量，生成的URL带多余JSON结构字符

解决方案 #

方案一：通过Lookup活动直接生成数组（推荐） #

1. 修改SQL查询：返回单列的用户ID数据集，避免手动拼接JSON

SELECT DISTINCT CONVERT(NVARCHAR(MAX), t.[id]) AS id 
FROM stage.extract_msgraphapi_users t 
LEFT JOIN stage.extract_msgraphapi_users s ON s.id = t.id

（加DISTINCT避免左连接产生重复ID）

2. 配置Lookup活动：在活动设置中勾选「返回所有行」，确保输出包含所有用户ID的数据集

3. 构造迭代数组：

   • 无需额外Set Variable活动，直接在Foreach循环的「迭代项」中使用表达式：

     @activity('Lookup用户ID').output.value[*].id
     

   • 该表达式会从Lookup返回的数据集里提取所有id字段，生成标准字符串数组

方案二：将SQL拼接的字符串转为数组 #

如果坚持使用STRING_AGG生成JSON格式字符串：

1. 优化SQL查询（移除未用到的左连接）：

SELECT '["' + STRING_AGG(CONVERT(NVARCHAR(MAX), t.[id]), '","') + '"]' AS id 
FROM stage.extract_msgraphapi_users t

2. 转换字符串为数组：在Set Variable活动中，用json()函数将字符串解析为数组：

@json(activity('Lookup用户ID').output.firstRow.id)

验证Foreach循环URL #

无论用哪种方案，Foreach循环中的URL构造表达式调整为：

@concat('users/', item(), '/?$expand=manager($levels=max;$select=id,displayName,userPrincipalName,createdDate)')

（去掉原表达式中的{}，因为item()直接返回ID字符串，无需占位符包裹）

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