文章插圖
? 作者簡介
文章插圖
?淡丹 數倉開發工程師5年數倉開發經驗，目前主要負責百得利MOBY新車業務二手車業務及售后服務業務系統數倉建設 業務需求在ETL任務之間調度時，我們有的時候會需要將上游的計算結果作為參數傳入到下游，針對這種業務需求，海豚調度器為我們提供了一些功能 。 具體如下：DolphinScheduler允許在任務間進行參數傳遞，目前傳遞方向僅支持上游單向傳遞給下游 。支持這個特性的任務類型有：
- Shell
- SQL
文章插圖
? 注意點
- 方向選擇為 OUT ， 只有當方向為 OUT 時才會被定義為變量輸出
- 數據類型可以根據需要選擇不同數據結構
- Value 部分不需要填寫
- 參數名字一定要和字段名字對應，否則不會識別
文章插圖
?注意此處，輸入參數不需要填寫，下游直接引用上游的變量即可 步驟3:上線驗證結果查看結果日志，可以看到下游節點已經接收到參數
文章插圖
? SHELL任務先看官網說明（鏈接）：https://dolphinscheduler.apache.org/zh-cn/docs/latest/user_doc/guide/parameter/context.html
- prop 為用戶指定；
- 方向選擇為 OUT ， 只有當方向為 OUT 時才會被定義為變量輸出；
- 數據類型可以根據需要選擇不同數據結構；
- value 部分不需要填寫；
文章插圖
?SHELL 節點定義的時候日志檢測到 ${setValue(key=value1)} 的格式時，會將 value1 賦值給 key，下游節點便可以直接使用變量 key 的值 。同樣，您可以在【工作流實例】頁面，找到對應的節點實例，便可以查看該變量的值 。
文章插圖
? 但在實際使用中官網的例子是跑不通的，這里面有小坑，上述在使用 ${setValue(key=value)} 這種形式傳參的時候必須用引號引起來 。 如下才能成功echo '${setValue(key=value)}'
案例所示
文章插圖
?上線執行后查看日志如下：
文章插圖
?可以看到結果已經打印出來 。如果取掉單引號會報如下錯誤：語法上就無法通過 。
文章插圖
?所以在SHELL中傳參的時候 ， 根據給的固定語法前 ， 必須得加上單引號 ， 否則語法無法通過 。上述的例子也僅僅是 Key 后面跟的常量參數，事實上我們往往都是需要動態傳參數的，所以 SHELL 的這種靜態傳遞參數給下游其實是沒有意義的，因為如果是靜態的，我們為什么不選擇in中輸入參數呢？ 如下圖所示
文章插圖
?我們在不同任務之間上下游之間的參數傳遞，往往是需要動態的/上游某個代碼執行后的結果傳遞給下游 。 我們不妨來試試這種方式是否可以？根據猜想我們編寫如下案例： 任務1：
文章插圖
? 任務2：
推薦閱讀
- 通過Thread Pool Executor類解析線程池執行任務的核心流程
- 光遇雙十一任務怎么做
- 原神雙重任務晉級與調查攻略
- 班主任工作任務總結模板
- 教學任務包括哪些方面教案中的 教學任務包括哪些方面
- 抖管家怎么提交任務
- 歷史科目教學工作任務總結
- 使命召喚戰區挑戰任務 使命召喚16戰區任務怎么完成
- 光遇的每日任務在哪里找 光遇的每日任務在哪里
- 電腦結束任務快捷鍵 電腦結束任務按哪一個鍵