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

注:整个测试用例截图。

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表内容如下:

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

step1:调度配置-节点上下文默认会生成一个本节点输出参数ouputs;

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

step2:提交节点。

以上游赋值节点赋值语言为ODPS SQL的为例

step1:依赖上游赋值节点;DataWorks_赋值节点三种赋值语言+数据库节点MySQL、三种取值方式使用案例

step2:节点上下文添加本节点输入参数,参数取名为inputs_odps_sql。

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

下游为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

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

SELECT * from `fuzhi_tb`;

fuzhi_tb表内容如下:

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

step1:调度配置-节点上下文-本节点输出参数添加赋值参数,默认会添加名为outputs的参数;

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

step2:提交节点。

下游为ODPS SQL节点:

SELECT '${inputs_mysql[0][0]}';

Hello

下游为shell节点:

echo '${inputs_mysql[0][0]}';

下游为pyodps3节点:

print ('${inputs_mysql[0][0]}');

若有收获,就点个赞吧

上一篇:DataWorks_数据服务_高级sql mybatis标签实现“可选”


下一篇:DataWorks_数据开发_EMR Spark节点_计算Pi和对接MaxCompute案例