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
有没有办法在 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