执行已经存在的脚本文件。
l Shell
脚本管理里的shell脚本调用。
脚本内参数写法:$1 $2 ,从1开始顺序往下编号,这里的1、2与工作流节点里配置的脚本参数项顺序对应。
图 Shell脚本界面
工作流节点配置里,参数的写法 ${day} ${username},多个参数间用空格分开。如果参数是从上游节点传递过来,用${}表示;如果是常量,直接写成20160913 或‘admin’(字符串要用单引号括起来) 。
图 IDE Script节点界面
l Python
脚本管理里的Python脚本调用。
脚本内参数写法如下图,从0开始顺序往下编号,这里的0、1与工作流节点里配置的脚本参数项顺序对应。
图 Python脚本界面
工作流节点配置里,参数的写法 ${day} ${username},多个参数间用空格分开。如果参数是从上游节点传递过来,用${}表示;如果是常量,直接写成20160913 或‘admin’ (字符串要用单引号括起来) 。
图IDE Script节点界面
l Hive(Spark SQL同理)
脚本管理里的Hive脚本调用。
脚本内参数写法:${day_id}。
工作流节点配置里变量写day_id,值如果是从上游节点传递过来,则用${}表示,如${day_id};如果是常量,直接写成20160913或 ‘admin’ (字符串要用单引号括起来) 。
图 IDE Script节点界面
图 脚本界面
相关参数说明:
字段名称 | 字段说明 |
节点Id | 由用户自定义,用来标识该服务的唯一性。 |
节点名称 | 由用户编写,用来标识该节点的名称。 |
项目 | 数据工厂中建立的项目。 |
脚本类型 | 目前系统支持脚本类型 (HIVE/SHELL/PYTHON/MR/SPARK/SPARK-SQL)。 |
脚本 | 选中项目中类型下的脚本。 |
出错重复次数 | 脚本运行时允许重复出错的次数。 |
脚本参数 | 选中的项目类型下的脚本需要传递的参数。 |
备注 | 由用户编写,用来简述该节点的相关信息。 |
l MR
脚本管理里的MR脚本调用。
脚本内参数写法:${output},多个参数间用逗号分开。
图MR脚本界面
工作流节点配置里变量写output,值如果是从上游节点传递过来,则用${}表示,写${output };如果是常量,直接写成常量值(如:20160913 ‘admin’) 即可(字符串要用单引号括起来) 。
图 IDE Script节点界面
l Spark
脚本管理里的Spark脚本调用。
脚本内参数写法:${output},多个参数间用逗号分开。
图 Spark脚本界面
工作流节点配置里变量写output,值如果是从上游节点传递过来,则用${}表示,写${output};如果是常量,直接写成20160913 ‘admin’ 即可(字符串要用单引号括起来) 。
图 IDE Script节点界面