所以，我在ADF中有一个“执行管道”，在它里面我有多个笔记本，它们正在向表写入查询。
我还有一个databricks notebook，它有一个发送电子邮件的类（notebook使用widget动态接收错误，这个错误将作为电子邮件的正文发送）
目前，我正在工作：如果笔记本失败，则整个“执行流水线”失败。现在，我想做的是，如果一个笔记本失败了，它会转到电子邮件笔记本，并发送一封电子邮件。
我试过这个：
我给notebook错误的参数是：
它确实有效，但它会使管道变得混乱！
理想情况下，我会喜欢这样的东西，但我在将失败的笔记本的错误从“执行管道”内部传递到外部时遇到了麻烦。
有人知道我该怎么做吗？或者有不同的方式？我也在考虑管道内部的Try-Catch，但我不确定它是否有效：/
Thank you！：D
1条答案
按热度按时间xqk2d5yq1#
为了将值从一个管道传递到另一个管道的Activity，您可以在设置变量Activity中使用管道返回值选项。
Wait on completion。return_val的变量，notebook输出作为该变量的值。@activity('Execute Pipeline1').output.pipelineReturnValue.return_val这里
return_val是我在子管道中使用的变量名。