創建函數流任務
更新時間 2025-01-13 16:37:08
最近更新時間: 2025-01-13 16:37:08
分享文章
本章介紹函數工作流如何創建函數流任務。
本章節主要介紹如何創建函數流任務和編排函數流任務。您可以根據實際業務場景來創建標準函數流或快速函數流。
- 標準模式面向普通的業務場景,支持長時間任務,支持執行歷史持久化和查詢,只支持異步調用,在函數流運行記錄頁面查詢執行結果。
- 快速模式面向業務執行時長較短,需要極致性能的場景,只支持流程執行時長低于5分鐘的場景,不支持執行歷史持久化,支持同步和異步調用。通過同步執行函數流接口進行函數流的同步執行,接口直接返回函數流執行結果,同時日志頁面查看上報到LTS的函數流執行日志。
說明快速函數流限時免費,歡迎體驗!
前提條件
已經在FunctionGraph控制臺創建函數。
操作步驟
1、登錄FunctionGraph控制臺,進入“函數流”頁面。
2、在“函數流”頁面,單擊“創建標準函數流”或“創建快速函數流”,進入新建函數流頁面。
3、編排函數流任務,請您根據實際應用進行函數流編排。
- 在函數流頁面,通過拖拽組件進行流程編排。
以下圖為例,將開始節點、函數、結束節點拖入編輯框內,并用連接線連接好。
編排函數流

- 分別單擊編輯框中的每個節點進行編輯。配置函數參數,參數說明如下表所示,帶*參數為必填項。
說明配置函數前確保已創建好函數,示例中的函數節點選擇函數2(函數執行返回result的值為函數調用事件內的input輸入值+2的結果值),參見下圖配置。
函數節點配置

函數參數說明
參數 說明 *應用 函數所屬應用,用戶創建函數時可以進行分組,
每個函數應用下面可以創建多個函數,在函數創建時可以指定其歸屬于某個函數應用。*函數 FunctionGraph中對應的函數。 說明僅對于Go函數支持返回流式數據:在函數詳情頁的“設置 > 高級設置”下,
打開“返回流式數據”開關即可*版本 FunctionGraph中函數對應的版本。 函數參數 流程中以json格式作為body參數在執行時傳入函數。
Key:填寫參數
Value:填寫參數值
DefaultValue:設置默認值,參數未獲取到值時,
默認獲取默認值操作:編輯或刪除設置的參數輸入過濾表達式(JSONPath) 基于上一個流程的json輸出參數,
可以使用JSONPath格式來選擇性的過濾出當前流程的輸入參數。輸出過濾表達式(JSONPath) 基于當前流程的json輸出參數,
可以使用JSONPath格式來選擇性的過濾出下一流程的輸出參數。
- 若您的函數流任務中配置了流程控制器,請參見下表進行配置,帶*參數為必填項。
流程控制器參數說明
類型 參數 說明 子流程 選擇子流程 選擇已創建的函數流任務。 是否等待子流程完成 默認選擇“是”。 輸入過濾表達式(JSONPath) 基于上一個流程的json輸出參數,可以使用JSONPath格式來選擇性的過濾出當前流程的輸入參數。 輸出過濾表達式(JSONPath) 基于當前流程的json輸出參數,可以使用JSONPath格式來選擇性的過濾出下一流程的輸出參數。 并行分支 *分支執行完成條件 所有分子執行完成:2個或2個以上分支時選擇該條件
一個分支執行完成:只有1個分支時選擇該條件
指定數目分支執行完成:2個或2個以上分支時其中某個分支可以選擇該條件輸入過濾表達式(JSONPath) 基于上一個流程的json輸出參數,可以使用JSONPath格式來選擇性的過濾出當前流程的輸入參數。 輸出過濾表達式(JSONPath) 基于當前流程的json輸出參數,可以使用JSONPath格式來選擇性的過濾出下一流程的輸出參數。 指定分支執行完成數目 當“分支執行完成條件”選擇指定數目分支執行完成時,支持自定義執行完成的數目。 *結果輸出路徑 輸入并行分支執行結果輸出位置,輸入值作為key,并行分支執行結果作為value,以json形式輸出。若未填寫,默認輸出路徑為:result。 開始節點 加入觸發器 用于標識流程的開始,一個流程只能有一個開始節點。如何創建函數流觸發器,請參見創建函數流觸發器。 異常處理 *是否重試 默認關閉,開啟后可以控制函數執行失敗后的下一步流程。
重試條件(JSONPath):例如: $.status == 500
重試間隔(1-30秒):默認重試間隔1S
最大重試次數(1-8):默認重試次數3次循環節點 *遍歷數組路徑(JSONPath) 需要遍歷的數組類型變量地址。 *迭代變量名稱 每次循環迭代,引用數組中元素的參數名稱。 結果輸出路徑(JSONPath) 指定全部迭代分支執行結果數組的輸出位置。 并發迭代數目 并發運行迭代分支的數目,限制0-100, 0代表并發拉起的數目無限制。 并發迭代時間間隔(秒) 每次迭代間隔的時間。 輸入過濾表達式(JSONPath) 基于上一個流程的json輸出參數,可以使用JSONPath格式來選擇性的過濾出當前流程的輸入參數。 輸出過濾表達式(JSONPath) 基于當前流程的json輸出參數,可以使用JSONPath格式來選擇性的過濾出下一流程的輸出參數。 時間等待 *延遲時間(秒) 默認1000秒。 服務節點 執行模式 定義服務節點中函數的執行順序。
串行模式:服務中的函數節點按照連線順序依次執行,可以嚴格保證函數的執行順序
并行模式:服務中的函數節點并行執行,不保證內部函數節點的執行順序輸入過濾表達式 通過JSONPath表達式對節點的輸入信息進行過濾。 輸出過濾表達式 通過JSONPath表達式對節點的輸出信息進行過濾。 條件分支 *分支類型 條件分支
默認分支
當一個分支選擇條件分支時,必須要有一個分支選擇默認分支。表達式 選擇“條件分支”,需要輸入JSONPath類型表達式。 輸入過濾表達式 通過JSONPath表達式對節點的輸入信息進行過濾。 輸出過濾表達式 通過JSONPath表達式對節點的輸出信息進行過濾。 結束節點 流程結束的標志 后面不能接任何節點。
- 流程中的所有節點參數配置完成后,單擊右上角的“保存”。
說明函數流中的節點改動后,必須先保存信息,再啟動函數流任務。
- 在新建函數流頁面,填寫相關信息,單擊“確定”,函數流保存成功。
輸入配置信息
| 參數 | 說明 |
|---|---|
| *名稱 | 輸入函數流名稱。 |
| *企業項目 | 選擇企業項目。 |
| 日志記錄 | 創建快速函數流,保存時需要選擇此參數。 ALL:為所有事件啟用日志記錄 ERROR:僅啟用錯誤日志記錄 NONE:關閉日志記錄 |
| 合并參數 | 將上一個節點的輸出與下一個節點的輸入合并為輸入。 |
| 描述 | 輸入函數流的簡要描述。 |
新建標準函數流

- 單擊“啟動”,在彈出的啟動執行頁面,支持輸入定義值或者直接啟動。此處選擇“輸入定義值”。
{
"input":3
}
啟動執行配置

說明輸入定義值必須是JSON格式的內容。
- 單擊“開始執行”,頁面右上角提示“啟動函數流xxx成功”。
- 單擊函數流任務名稱,進入函數流任務詳情,查看函數流執行結果。
查看執行結果
