来自管道输出的 Azure 数据流源

Question

是否可以创建一个从管道中事件的输出获取数据的数据流？

类似这样的事情:

我想创建一个具有 Azure 函数事件的管道来处理一些数据，然后将处理后的数据传递到数据流。

但显然数据流只接受数据集作为源。

Answer 1

如果您的 Azure Function Activity 提供了一个 Json 数组，那么您可以按照以下过程进行操作:

这里我使用了 Lookup 而不是 Azure Function，它提供了以下输出:

在 ForEach Activity 中使用此输出，并为名称对象生成数组，如下所示，并在 ForEach 内附加变量 activivty:

 [ "Rakesh", "Bhavan", "sai", "kiran", "kowsik", "Rakesh", "kowsik", "arun", "sai", "virat" ]

现在创建一个数据流并使用数组参数。将上述数组从管道传递到数据流参数:

在 DataFlow 内部采用具有虚拟数据集和虚拟列的源，使用派生列表达式 unfold($arr) 从数组参数生成列，如下所示:

派生列结果，列:

但是上述过程仅适用于单个数组。因此，如果您有多个数组，则必须将 Azure 函数输出存储到 blob 或 ADLS，然后按照 @Ziya Mert Karakas 的建议将其返回到数据流。