ASW工作流最佳實踐（二）：使用ASW并發(fā)調(diào)用函數(shù),wcf工作流例子-ESG跨境

ASW工作流最佳實踐（二）：使用ASW并發(fā)調(diào)用函數(shù),wcf工作流例子

ASW工作流最佳實踐(二):使用ASW并發(fā)調(diào)用函數(shù)

在很多場景下，比如音視頻轉(zhuǎn)碼、ETL作業(yè)處理、基因數(shù)據(jù)處理等。，我們可以通過工作流并行調(diào)用云函數(shù)來并行處理任務(wù)，大大提高了任務(wù)處理的吞吐量，滿足了應(yīng)用場景的高實時性和并發(fā)性。

本期主要分享如何利用ASW的地圖節(jié)點能力進(jìn)行并發(fā)數(shù)據(jù)求和計算。

01。

創(chuàng)建一個函數(shù)

1.登錄“云函數(shù)控制臺”，創(chuàng)建一個云函數(shù)，函數(shù)名為Sum，運行環(huán)境Python 3.6。

云平臺地址:https://console.cloud.tencent.com/scf

# *編碼:utf8 *

導(dǎo)入json

def mainhandler(事件，上下文):

總和= 0

對于事件中的I[值]:

總和+= i

返回總和

02。

創(chuàng)建工作流

1.登錄應(yīng)用與編排服務(wù)流程控制臺，在工作流頁面點擊“新建”，進(jìn)入創(chuàng)建工作流頁面，點擊“入門模板”，選擇“映射周期”模板。

ASW中的Map節(jié)點將遍歷輸入中的數(shù)組類型參數(shù)，并為數(shù)組中的每個元素并行執(zhí)行其串行節(jié)點。Map類似于編程語言中的foreach，但是節(jié)點循環(huán)任務(wù)是并發(fā)執(zhí)行的。

https://console.cloud.tencent.com/asw ASW控制臺地址

2.在代碼中修改迭代器下的States節(jié)點中的state01，以調(diào)用sum函數(shù)，如以下工作流中所定義:

{

注釋:使用Map節(jié)點循環(huán)處理數(shù)組array中的數(shù)據(jù)，

StartAt: MapState，

國家:{

映射狀態(tài):{

類型:地圖，

ItemsPath: $。數(shù)組，

結(jié)果路徑:$。結(jié)果，

MaxConcurrency: 2，

接下來:FinalState，

迭代器:{

StartAt:狀態(tài)01，

國家:{

狀態(tài)01: {

類型:任務(wù)，

注釋:調(diào)用求和函數(shù)，

資源:qrn:QCS:ASW:AP廣州:123456789:SDK:JSON:q cloud:SCF:Invoke/sum/$ DEFAULT/DEFAULT，

結(jié)束:真的

}

}

}

},

最終狀態(tài):{

類型:通過，

結(jié)束:真的

}

ItemsPath指定一個作為Map節(jié)點循環(huán)的數(shù)組。

MaxConcurrency指定Map節(jié)點并發(fā)調(diào)用的函數(shù)數(shù)量。

迭代器是為Map節(jié)點的循環(huán)任務(wù)定義的。

3.單擊下一步。在配置基本信息頁面，輸入工作流名稱，選擇運行角色和工作流類型，點擊完成，完成工作流創(chuàng)建。

03。

運行工作流

1.在工作流列表中，點擊“名稱”鏈接進(jìn)入工作流。在彈出的“開始執(zhí)行”窗口中，輸入JSON格式的數(shù)組array。例如:

{

數(shù)組:[{

值:[1，2，3，4，5]

},

{

值:[4，2，3，1，5]

},

{

值:[1，0，8，4，5]

},

{

值:[7，2，3，2，5]

}

]

}

2.單擊“確定”。狀態(tài)執(zhí)行完成后，您可以在詳細(xì)信息頁面上查看執(zhí)行結(jié)果?；瑒拥巾撁娴撞?，在執(zhí)行歷史下，可以查看子節(jié)點的操作。我們可以看到Map節(jié)點會調(diào)用MaxConcurrency為2的sum函數(shù)，每個sum函數(shù)的參數(shù)都是數(shù)組array的一個項。

3.點擊參考資料中的云函數(shù)鏈接，可以直接跳轉(zhuǎn)到云函數(shù)控制臺，查看函數(shù)執(zhí)行的細(xì)節(jié)。

特別聲明：以上文章內(nèi)容僅代表作者本人觀點，不代表ESG跨境電商觀點或立場。如有關(guān)于作品內(nèi)容、版權(quán)或其它問題請于作品發(fā)表后的30日內(nèi)與ESG跨境電商聯(lián)系。