上云无忧 > 文档中心 > 天翼云数据治理中心 DataArts Studio EL表达式 - Job内嵌对象
数据治理中心 DataArts Studio
天翼云数据治理中心 DataArts Studio EL表达式 - Job内嵌对象

文档简介:
本章节主要介绍DataArts Studio的Job内嵌对象功能。 Job为作业对象,提供了获取作业中上一节点的输出消息、作业调度计划时间、作业执行时间等属性和方法。
*产品来源:中国电信天翼云。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠

Job为作业对象,提供了获取作业中上一节点的输出消息、作业调度计划时间、作业执行时间等属性和方法。

属性和方法

属性说明

属性 类型 描述
name String 作业名称。
planTime java.util.Date 作业调度计划时间,即周期调度配置的时间,例如每天凌晨1:01调度作业。
startTime java.util.Date 作业执行时间,有可能与planTime同一个时间,也有可能晚于planTime(由于作业引擎繁忙等)。
eventData String 当作业使用事件驱动调度时,从通道获取的消息。
projectId String 当前数据开发模块所处项目ID。

方法说明

方法 描述
String getNodeStatus(String nodeName) 获取指定节点运行状态,成功状态返回success,失败状态返回fail。例如,判断节点是否运行成功,可以使用如下判断条件,其中test为节点名称:#{(Job.getNodeStatus("test")) == "success" }。
String getNodeOutput(String nodeName) 获取指定节点的输出。此方法只能获取前面依赖节点的输出。
String getParam(String key) 获取作业参数。注意此方法只能直接获取当前作业里配置的参数值,并不能获取到父作业传递过来的参数值,也不能获取到工作空间里面配置的全局变量,作用域仅为本作业。这种情况下建议使用表达式${job_param_name},既可以获取到父作业传递过来的参数值,也可以获取到全局配置的变量。
String getPlanTime(String pattern) 获取指定pattern的计划时间字符串,pattern为日期、时间模式,请参考日期和时间模式。
String getYesterday(String pattern) 获取执行pattern的计划时间前一天的时间字符串,pattern为日期、时间模式,请参考日期和时间模式。
String getLastHour(String pattern) 获取执行pattern的计划时间前一小时的时间字符串,pattern为日期、时间模式,请参考日期和时间模式。
String getRunningData(String nodeName) 获取指定节点运行中记录的数据。此方法只能获取前面依赖节点的输出。当前只支持获取DLI SQL节点运行中记录的DLI作业id。例如,想要获取DLI节点第3条语句的job ID(DLI节点名为DLI_INSERT_DATA),可以这样使用:#{JSONUtil.path(Job.getRunningData("DLI_INSERT_DATA"),"jobIds[2]")}。
String getInsertJobId(String nodeName) 返回指定DLI SQL或Transform Load节点第一个DLI Insert SQL语句的作业ID,不指定参数nodeName时,获取前面一个节点第一个DLI Insert SQL语句的作业ID,如果无法获取到作业ID,返回null值。

举例

获取作业中节点名称为test的输出,EL表达式如下:

#{Job.getNodeOutput("test")}
相似文档
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部