我有一个vary simple/toy pipeline,其中有一个pyspark笔记本,它有一个退出值,一个设置变量activity,设置为退出值,还有一个笔记本,它是用变量参数化的。
我成功地设置了变量,但是我似乎无法将此变量读入input_values
笔记本。笔记本看起来像下面,也相当简单。
我的管道参数看起来如下所示。但是我的退出值只是显示为"hello"
我还尝试过直接在笔记本中访问变量(没有参数化),但这导致了一个错误。当我试图查看这种类型的行为的文档时,它通常指向从另一个笔记本调用笔记本,因此调用者/被调用者笔记本,例如来自this documentation的示例。这似乎是创建DAG的倒退,所以我不想这么做,我想做的似乎是可能的,我看到一个类似here的例子,但我似乎不能让它工作。
有人能给我指一下说明如何完成我想要的东西的文档吗?或者上面的文档中有我遗漏的东西吗?
编辑:
我尝试将msg
参数设置为@activity('exit_values').output.status.Output.result.exitValue
,这是我成功地将my_message
变量设置为的,但也不起作用。
成功
我并不觉得自己很聪明,但我将把这个问题留给可能处于相同位置的任何人。我在管道上设置了msg
参数,而不是在单个笔记本上。我通过在笔记本上设置参数成功地运行了它。
1条答案
按热度按时间py49o6xq1#
我在笔记本上设置了参数,运行成功。
这是将值传递给“笔记本”参数的正确方法。
在上面的
@variables('msg_var')
是一个动态内容,而不是默认值。管道参数不支持动态内容在这里。此外,我们还必须通过创建一个与“笔记本”(Notebook)活动的“基础参数”(Base parameters of Notebook)同名的参数来给予“笔记本”(Notebook)管线的值。
在这里,它支持动态内容,所以像下面这样给予变量。
笔记本输出: