Azure 数据工厂查找和针对每个

Question

我有一个数据工厂管道，我希望它可以遍历 SQL 查找 activity 的行。我已将查询缩小到三列和 500 行。

我知道要在 table 中引用一个值，我使用：

@{activity('lookupActivity').output.value[row#].colname}

但是，for each 需要迭代一些东西。我的第一个猜测是将一些数组变量设置为返回的 sql 查询的行。那么我要将该变量设置为什么？

@{activity('lookupActivity').output.value?

最后，似乎几乎所有数据在 ADF 中都表示为 json，这是真的吗？我如何才能将此查找的输出视为 json，以便了解我的动态内容需要是什么样子？

Answer 1

您可以将输出值用于每个 activity 并一次处理一个。您可以根据需要进行顺序或并行操作。

Answer 2

你是对的，一切（几乎）都是 JSON。（例外：

所以你可以把你的 @activity('lookupActivity').output.value 这是一个数组放到设置选项卡上的 foreach activity 中，就像这样

然后在 foreach 循环中，将其中一列的当前值引用为 @item().colname。

Azure Data Factory Lookup and For Each