Azure Data Factory中如何从Lookup Activity添加ForEach Loop实现逐行POST请求
实现CSV逐行处理并传递至Web Activity的步骤
- 确认CSV读取输出的数组格式:如果用Lookup Activity读取CSV,它的输出自带
value数组,每个数组元素对应CSV的一行数据(键是列名,值是单元格内容)。要是用的其他读取方式,得确保输出能转成可遍历的数组。 - 配置ForEach Loop的遍历源:
打开ForEach Loop的设置面板,在Items输入框里填表达式:@activity('你的读取CSV活动名称').output.value,把括号里的名称换成你实际用的活动名,这样循环就会挨个遍历CSV的每一行。 - 在Web Activity里调用当前行数据:
到Web Activity的Body区域,用@item()来获取当前循环的行数据:- 要把整行转成JSON发请求,直接写
@item()就行; - 要指定特定列,比如只传
id和name,就构造这样的JSON:{ "id": "@item().id", "name": "@item().name" }
- 要把整行转成JSON发请求,直接写
- 测试验证:运行Pipeline后,ForEach会自动逐行触发Web Activity,每一次POST请求都会带上当前行的对应数据。
内容的提问来源于stack exchange,提问作者HushGr
相关产品推荐
相关产品推荐

