DataLeap 支持您通过设置任务的输入输出参数,可实现参数在上游和下游任务之间进行传递,该参数的内容值,可来源于上游任务的输出结果、项目参数或是自定义参数值。本文将为您介绍如何配置上游任务输出参数和下游任务输入参数。
仅支持 Shell、Python 任务,将最后一行 stdout/err 的实例运行结果,作为输出变量参数,并通过“outputs”参数传递给下游任务作为输入参数变量。
任务设置输入参数后,可在任务内部进行使用,其使用方式与时间参数使用方式不同:
输入参数配置具体分为以下三类:
支持将 Shell、Python 任务,最后一行 stdout/err 的实例运行结果,作为输出变量参数,通过“outputs”进行传递。
说明



在输入参数中手动添加参数类型为项目,项目参数可供项目全局使用。
项目参数使用案例详见参数信息-使用案例。
输入参数也支持以自定义参数内容的方式,进行上下游传参。
在任务输入参数界面中,单击手动添加按钮,进入输入参数添加窗口:
自定义参数使用案例详见3.4.4 任务输入参数。
设置任务的输出参数,输出参数定义完成且任务上线后,即可在下游节点中使用,作为下游节点的输入参数的取值。输出参数的取值分为常量和变量两种类型。
常量取值:常量为固定字符串,需要在任务的输出参数中进行定义。
变量取值:包含上游任务输出结果参数和系统支持的全局变量。
其中系统支持的全局变量参数不需要在输出参数中定义,由系统提供,具体包含以下几种:
参数变量 | 说明 | 枚举值 |
|---|---|---|
{{taskId}} | 任务 ID | 无 |
{{instanceStatus}} | 实例状态 |
|
{{taskType}} | 任务类型 | EMR、EMR Doris、EMR StarRocks、EMR Serverless Spark 类型:
|
ByteHouse 任务类型:
| ||
流式 Flink 任务类型:
| ||
通用类型:
| ||
交互式分析任务类型:notebook | ||
离线通道任务:common-dts-batch | ||
LAS 类型:
| ||
{{taskId}} | 任务 ID | 无 |
{{taskName}} | 任务名称 | 无 |
{{taskOwner}} | 任务责任人 | 无 |
{{instanceId}} | 实例 ID | 无 |
{{taskTime}} | 实例对应的业务时间 | 无 |
{{scheduleRunTime}} | 实例设定的运行时间 | 无 |
{{startTime}} | 实例实际开始运行时间 | 无 |
{{endTime}} | 实例实际结束运行时间 | 无 |
{{triggerType}} | 触发类型 | 包括系统调度、重跑类型 |
{{trackingUrl}} | 实例执行 Tracking URL 信息 | 无 |
输入输出参数配置完成后,您便可开始任务的调试或提交发布操作。详见5 提交上线。