tencent cloud

数据开发治理平台 WeData

产品动态
动态发布记录(2026年)
产品简介
产品概述
产品优势
产品架构
产品功能
应用场景
购买指南
计费概述
产品版本购买说明
执行资源购买说明
购买方式
欠费说明
退费说明
准备工作
账号和权限管理概述
添加白名单/安全组(可选)
通过 Microsoft Entra ID(Azure AD)单点登录(SSO)WeData
操作指南
管理控制台
项目管理
数据集成
Studio
数据开发
数据分析
数据科学
数据治理(with Unity Semantics)
API 文档
History
Introduction
API Category
Making API Requests
Smart Ops Related Interfaces
Project Management APIs
Resource Group APIs
Data Development APIs
Data Asset - Data Dictionary APIs
Data Development APIs
Ops Center APIs
Data Operations Related Interfaces
Data Exploration APIs
Asset APIs
Metadata Related Interfaces
Task Operations APIs
Data Security APIs
Instance Operation and Maintenance Related Interfaces
Data Map and Data Dictionary APIs
Data Quality Related Interfaces
DataInLong APIs
Platform Management APIs
Data Source Management APIs
Data Quality APIs
Platform Management APIs
Asset Data APIs
Data Source Management APIs
Data Types
Error Codes
WeData API 2025-08-06
服务等级协议
相关协议
隐私协议
数据处理和安全协议
联系我们
词汇表

参数传递

PDF
聚焦模式
字号
最后更新时间: 2025-04-15 21:38:41

功能简介

用于支持参数在上下游之间传递。例如:将当前任务的计算结果作为参数传递给子任务使用。多个结果可通过列号指定传递对象。
支持范围:Hive SQL、JDBC SQL、Python、Shell、Spark SQL、DLC SQL、Impala、TCHouse-P、DLC PySpark。

参数配置说明

1. 输出当前任务参数

若需要将参数从当前任务传递到下游,则在参数传递中勾选输出当前任务参数并配置参数信息。
输出参数传递给子任务,取值包含以下两种类型:
变量(n、m从0开始计算),支持传递二维数组,具体配置方式如下:
$[n][m]:获取第n行第m列的数据。
$[n][*]:表示获取第n行的数据。
$[*][n]:表示获取第n列的数据。
$[*][*]:表示获取所有行列的数据。
$[0]:表示获取首行第一列的数据。
常量:设置常量作为输出参数。
例如:父任务 A,在代码中计算结果有3列,分别为123,234, 1234, 在此配置中定义一个输出参数名 mark_id, 填写 mark_id = $[0],表示取计算结果首行第一列的值。

1. 引用父任务参数

若当前任务需要引用父任务中定义的参数,则在参数传递中勾选引用父任务参数。
填入定义的引入参数,选择该参数取值的父任务的输出参数(没有父节点则无选项),例如:子任务 B,任意定义参数名 mark_id,取值选择节点 A.mark_id,在代码中使用 ${mark_id},便会将 ${mark_id} 替换成字符串123 。
示例:如图定义参数名 a,取上游父任务 hivesql_1 中定义的参数 a;定义参数名 b,取上游父任务 hivesql_1 中定义的参数 b。




使用示例

分为三类:SQL 类、Shell 类、Python 类,以下为三种类型的使用示例(下文以传递常量为例,也支持传递变量)。
类型
任务类型
作为输出方(上游)
作为输入方(下游)
备注
参数配置
代码
参数配置
代码
SQL 类
Hive SQL
JDBC SQL
Spark SQL
DLC SQL
Impala
TCHouse-P



SELECT "This is the value of the parameter"


SELECT '${parameter}' AS parameter_value;

Shell 类
Shell



echo "This is the value of the parameter"


expr ${parameter}

Python 类
Python



print("This is the value of the parameter")


print('${parameter}')

DLC PySpark 类
DLC PySpark

from dlcutils import dlcutils

dlcutils.params.save([["param1","param2","param3"],["param4","param5","param6"]])

print('${parameter}')
作为输出方的使用限制:仅 DLC 引擎的内核版本为 Standard-S1.1 和 Standard-S1.1(native),且功能上线(2025年3月30日)后新建的引擎支持,之前新建的引擎升级后才可支持,如需升级引擎请联系 DLC 运维同学。



帮助和支持

本页内容是否解决了您的问题?

填写满意度调查问卷,共创更好文档体验。

文档反馈