Azure 数据工厂 v2:Activity 执行管道输出

Azure Data Factory v2: Activity execute pipeline output

有没有办法在 activity "Execute pipeline" 中引用已执行管道的输出?

即:master pipeline依次执行2个pipeline。第一个管道生成一个自己创建的 run_id,需要作为参数转发给第二个管道。

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

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

执行管道 activity 只是另一个 activity,其输出可以被其他活动捕获。 https://docs.microsoft.com/en-us/azure/data-factory/control-flow-execute-pipeline-activity#type-properties

如果你想使用之前执行的管道的runId,它看起来像这样:

@activity('ExecutePipelineActivityName').output.pipeline.runId

希望对您有所帮助!

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

由于某些奇怪的原因,ExecutePipeline 的输出不是作为 JSON 对象而是作为字符串返回。因此,如果您尝试 select 一个 属性 这样的输出 @activity('ExecutePipelineActivityName').output.something 那么您会收到此错误:

属性 select离子在 'String'

类型的值上不受支持

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