DataWorks_赋值节点三种赋值语言+数据库节点MySQL、三种取值方式使用案例

赋值语言

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节点：
SELECT '${inputs_shell[0]}';

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]}');