Azure 数据工厂 v2 : Activity execute pipeline output

Question

有没有办法在“执行管道”事件中引用已执行管道的输出？

即:主管道按顺序执行2个管道。第一个管道生成一个自己创建的 run_id，需要将其作为参数转发给第二个管道。

我已阅读文档并检查主管道是否记录了第一个管道的输出，但看起来这不可能直接实现？

到目前为止，我们只使用了 2 个管道，没有主管道，但我们希望更多地重用逻辑。目前我们有 1 个管道调用下一个管道并转发 run_id。

更新2023-03-31从 2023 年初开始，我们可以通过使用新引入的系统变量“管道返回值”从管道获得输出。

官方文档在这里: https://learn.microsoft.com/en-us/azure/data-factory/tutorial-pipeline-return-value

Answer 1

ExecutePipline 目前无法将任何内容从其内部传递到其输出。您只能获取 runID 或名称。

出于某种奇怪的原因，ExecutePipeline 的输出不是作为 JSON 对象返回，而是作为字符串返回。因此，如果您尝试选择像这样的输出属性 @activity('ExecutePipelineActivityName').output.something 那么您会收到以下错误:

“String”类型的值不支持属性选择

我发现我必须使用以下命令来获取运行 ID:@json(activity('ExecutePipelineActivityName').output).pipelineRunId