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



是否有方法引用活动中已执行管道的输出"执行管道"?

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

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

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

更新2023-03-31截至2023年初,我们可以通过使用新引入的系统变量"管道返回值"从管道中获得输出。

官方文件如下:https://learn.microsoft.com/en-us/azure/data-factory/tutorial-pipeline-return-value

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

出于某种奇怪的原因,ExecutePipeline的输出不是以JSON对象的形式返回,而是以字符串的形式返回。因此,如果你试图选择像@activity('ExecutePipelineActivityName').output.something这样的输出属性,那么你会得到这个错误:

属性选择不支持"字符串"类型的值

我发现我必须使用以下方法才能获得跑步ID:@json(activity('ExecutePipelineActivityName').output).pipelineRunId

execute pipeline活动只是另一个具有其他活动可以捕获的输出的活动。https://learn.microsoft.com/en-us/azure/data-factory/control-flow-execute-pipeline-activity#type-属性

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

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

希望这能有所帮助!

相关内容

  • 没有找到相关文章

最新更新