我们有ForEach迭代,在其中我们有Execute Pipeline活动。此活动调用具有复制活动的子管道。

我们有与每个迭代相关联的ID和唯一的SELECT查询来复制数据。但我们还希望在每次成功执行Pipeline活动后更新已处理的行数。存储的Proc活动(或任何其他方式)应处理行计数并更新到数据库中。这在SSIS中非常简单,但在Azure Data Factory中无法找到方法。
我已经提交了this,所以post,但这不符合我们的要求。我们不想更改子管道中的任何内容。
发布于 2018-09-19 21:58:53
目前,执行流水线活动仅输出子流水线的流水线运行id和流水线名称。
最简单的方法是将存储过程活动移动到子管道中。如果你不想更改子管道,也许你可以编写custom activity来获得基于管道运行id的管道运行细节。
https://stackoverflow.com/questions/52386193
复制相似问题