Azure数据工厂v2:活动执行管道输出 [英] Azure Data Factory v2: Activity execute pipeline output

问题描述

是否可以在活动执行管道"中引用已执行管道的输出?

Is there a way to reference the output of an executed pipeline in the activity "Execute pipeline"?

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

I.e.: master pipeline executes 2 pipelines in sequence. The first pipeline generates an own created run_id that needs to be forwarded as a parameter to the second pipeline.

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

I've read the documentation and checked that the master pipeline log the output of the first pipeline, but it looks like that this is not directly possible?

到目前为止，我们仅使用了2个没有主管道的管道，但是我们想更多地重用逻辑.当前，我们有1个管道调用下一个管道并转发run_id.

We've used until now only 2 pipelines without a master pipeline, but we want to re-use the logic more. Currently we have 1 pipeline that calls the next pipeline and forwards the run_id.

推荐答案

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

ExecutePipline currently cannot pass anything from its insides to its output. You can only get the runID or name.

出于某些奇怪的原因，ExecutePipeline的输出不是作为JSON对象而是作为字符串返回.因此，如果您尝试选择类似@activity('ExecutePipelineActivityName').output.something这样的输出属性，则会出现此错误:

For some weird reason, the output of ExecutePipeline is returned not as a JSON object but as a string. So if you try to select a property of output like this @activity('ExecutePipelineActivityName').output.something then you get this error:

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

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

I found that I had to use the following to get the run ID: @json(activity('ExecutePipelineActivityName').output).pipelineRunId

这篇关于Azure数据工厂v2:活动执行管道输出的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！