除通用Shell節點、PyODPS節點外,其他類型節點均可參考SQL類型節點(例如,ODPS SQL)的配置方式定義參數并為參數賦值。通用Shell節點、PyODPS節點的調度參數使用存在部分差異。本文為您介紹各類型節點的調度參數配置示例。
SQL類型節點及離線同步節點
SQL類型節點及離線同步節點的調度參數配置與多數類型節點的配置相似,可供多數節點參考使用。本文以ODPS SQL節點為例,為您展示如何為系統內置變量及自定義參數賦值,并在代碼中進行調用。如上圖,在參數賦值區域為參數賦值,然后進入代碼調用區域引用系統內置變量var1、var3,自定義參數var2、var4,常量var5。賦值示例如下:
說明 部分節點可能不支持使用調度參數。各節點是否支持使用調度參數,詳情請參考具體的節點文檔。
- 系統內置變量var1賦值取業務時間:
var1=$bizdate
- 系統內置變量var3賦值取定時時間:
var3=$cyctime
- 自定義參數var2賦值取業務時間:
var2=${yyyymmdd}
- 自定義參數var4賦值取定時時間:
var4=$[yyyymmddhh24:mi:ss]
- 常量var5參數賦值為abc:
var5=abc
PyODPS節點
為避免代碼入侵,PyODPS節點不支持在代碼中直接使用
配置及使用調度參數,詳情請參見配置并使用調度參數,更多調度參數的賦值方式,詳情請參見調度參數支持的格式。${param_name}
格式的字符串替換定義的變量。執行代碼前,您需要從類型為dict(字典對象)的args
全局變量中獲取調度參數。如上圖,在參數賦值區域為參數賦值,然后進入代碼調用區域引用內置參數var1,自定義參數var2、var3。添加字典對象后的參數為args['var1']
、args['var2']
、args['var3']
。賦值示例如下:- 內置參數var1賦值取業務時間:
var1=$bizdate
- 自定義參數var2賦值取業務時間:
var2=${yyyymmdd}
- 自定義參數var3賦值取業務時間:
var3=$[yyyymmdd]
通用Shell節點配置示例
通用Shell節點中的變量不允許自定義命名,只能以
$1
、$2
、$3
...命名(參數序號由小到大,依次遞增),當參數的數量大于10時,請使用${10}
的方式聲明變量。如上圖,在參數賦值區域為參數賦值,然后進入代碼調用區域定義內置參數$1,自定義參數$2、$3。賦值示例如下:說明 通用Shell節點僅支持使用表達式方式為參數賦值。多個參數賦值使用空格分隔,并且參數取值與定義參數時的順序對應。例如,上圖Shell節點定義的第一個參數為$1,則參數賦值區域序號第一的賦值內容
$bizdate
即為$1的參數取值。- 內置參數$1賦值取業務時間:
$bizdate
- 自定義參數$2賦值取業務時間:
${yyyymmdd}
- 自定義參數$3賦值取定時時間:
$[yyyymmdd]
離線同步示例
調度參數在數據集成的典型應用場景,詳情請參見場景:調度參數在數據集成的典型應用場景。