在 azure 数据工厂管道的 for-each 活动中使用映射数据流。

Question

场景: 我有SQL DB CDC净变化进入csv文件。在管道中，对于csv文件中的每一行都需要检查更新，插入和删除，并在我的仓库DB中做一些改变。

流水线:

映射数据流。

问题：:

如何在数据流中使用foreach中的item()，从csv文件中获取记录并进行处理。我在数据流的源步骤中没有看到任何字段选项。

Answer 1

首先，你可以在数据流中添加一个参数。

然后在数据流中，点击数据流，用管道表达式设置数据流参数。

然后你可以设置Foreach item() 作为数据流的参数。

现在，你可以在数据流中使用foreach中的item()从csv文件中获取记录并进行处理。

希望这对你有帮助。

Answer 2

这里不需要使用ForeEach，数据流可以从你的Cv文件中读取每一行记录。数据流可以从你的CDC源文件中读取每一行，你可以在Alter Row转换中应用相应的插入、更新、合并、删除操作作为策略。