注:整个测试用例截图。
使用说明
赋值语言 |
outputs取值 |
outputs参数格式 |
outputs参数大小限制
|
赋值节点:ODPS SQL |
最后一行SELECT语句的输出作为赋值参数,添加为赋值节点的本节点输出参数,供其他节点引用。 |
将输出结果作为一个二维数组传递至下游。 |
传递值最大为2 MB。如果赋值语句的输出结果超过该限制,赋值节点会运行失败。 |
赋值节点:SHELL |
最后一行ECHO语句的数据,添加为赋值节点的本节点输出参数,供其他节点引用。 |
将输出结果基于逗号(,)分割为一维数组。 |
|
赋值节点:PYTHON(python2) |
最后一行PRINT语句的输出,添加为赋值节点的本节点输出参数,供其他节点引用。 |
将输出结果基于逗号(,)分割为一维数组。 |
|
数据库节点:MySQL |
最后一行SELECT语句的输出作为赋值参数,添加为赋值传参的输出参数,供其他节点引用。 |
将输出结果作为一个二维数组传递至下游。 |
使用案例
赋值语言 |
赋值节点outputs取值 |
赋值节点调度配置 |
下游节点调度配置 |
下游节点取值方式 |
下游节点返回结果 |
赋值节点:ODPS SQL |
SELECT * FROM fuzhi_tb; fuzhi_tb表内容如下: |
step1:调度配置-节点上下文默认会生成一个本节点输出参数ouputs; step2:提交节点。 |
以上游赋值节点赋值语言为ODPS SQL的为例 step1:依赖上游赋值节点; step2:节点上下文添加本节点输入参数,参数取名为inputs_odps_sql。 |
下游为ODPS SQL节点: SELECT '${inputs_odps_sql[0][0]}'; |
Hello |
下游为shell节点: echo '${inputs_odps_sql[0][0]}'; | |||||
下游为pyodps3节点: print ('${inputs_odps_sql[0][0]}') | |||||
赋值节点:SHELL |
echo 'Data','我是赋值节点2赋值语言shell'; |
下游为ODPS SQL节点: |
Data |
||
下游为shell节点: echo '${inputs_shell[0]}'; | |||||
下游为pyodps3节点: print ('${inputs_shell[0]}') | |||||
赋值节点:PYTHON(python2) |
print "Works!,我是赋值节点3赋值语言是python" |
下游为ODPS SQL节点: SELECT '${inputs_python[0]}'; |
Works! |
||
下游为shell节点: echo '${inputs_python[0]}'; | |||||
下游为pyodps3节点: print ('${inputs_python[0]}') | |||||
数据库节点:MySQL |
SELECT * from `fuzhi_tb`; fuzhi_tb表内容如下: |
step1:调度配置-节点上下文-本节点输出参数添加赋值参数,默认会添加名为outputs的参数; step2:提交节点。 |
下游为ODPS SQL节点: SELECT '${inputs_mysql[0][0]}'; |
Hello |
|
下游为shell节点: echo '${inputs_mysql[0][0]}'; | |||||
下游为pyodps3节点: print ('${inputs_mysql[0][0]}'); |
若有收获,就点个赞吧