azure-data-factory - 在 azure data-factory 管道的 for-each 活动中使用映射数据流

Question

场景：我有 SQL DB CDC 网络更改进入 csv 文件。在 csv 文件中的每一行的管道中，需要检查更新、插入和删除，并在我的仓库数据库中进行一些更改。

管道：

映射数据流：

问题：

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

score 1 · Accepted Answer

这里不需要使用 ForEach。数据流可以从您的 CDC 源文件中读取每一行，并且您可以将适当的插入、更新、合并、删除操作作为更改行转换中的策略应用。

score 0 · Accepted Answer

首先，您可以在数据流中添加一个参数：

然后跳出数据流，点击数据流，用管道表达式设置数据流参数：

然后您可以将 Foreach 设置item()为数据流参数：

现在，您可以在数据流中使用 foreach 中的 item() 并从 csv 文件和进程中获取该记录。

希望这可以帮助。

2 回答 2