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

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

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

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

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

01。

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

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

云平臺(tái)地址:https://console.cloud.tencent.com/scf

# *編碼:utf8 *

導(dǎo)入json

def mainhandler(事件，上下文):

總和= 0

對(duì)于事件中的I[值]:

總和+= i

返回總和

02。

創(chuàng)建工作流

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

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

https://console.cloud.tencent.com/asw ASW控制臺(tái)地址

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

{

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

StartAt: MapState，

國(guó)家:{

映射狀態(tài):{

類(lèi)型:地圖，

ItemsPath: $。數(shù)組，

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

MaxConcurrency: 2，

接下來(lái):FinalState，

迭代器:{

StartAt:狀態(tài)01，

國(guó)家:{

狀態(tài)01: {

類(lèi)型:任務(wù)，

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

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

結(jié)束:真的

}

}

}

},

最終狀態(tài):{

類(lèi)型:通過(guò)，

結(jié)束:真的

}

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

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

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

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

03。

運(yùn)行工作流

1.在工作流列表中，點(diǎn)擊“名稱(chēng)”鏈接進(jìn)入工作流。在彈出的“開(kāi)始執(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ì)信息頁(yè)面上查看執(zhí)行結(jié)果?；瑒?dòng)到頁(yè)面底部，在執(zhí)行歷史下，可以查看子節(jié)點(diǎn)的操作。我們可以看到Map節(jié)點(diǎn)會(huì)調(diào)用MaxConcurrency為2的sum函數(shù)，每個(gè)sum函數(shù)的參數(shù)都是數(shù)組array的一個(gè)項(xiàng)。

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

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