ASW工作流最佳实践（二）：使用ASW并发调用函数,wcf工作流例子-ESG跨境

ASW工作流最佳实践（二）：使用ASW并发调用函数,wcf工作流例子

ASW工作流最佳实践(二):使用ASW并发调用函数

在很多场景下，比如音视频转码、ETL作业处理、基因数据处理等。，我们可以通过工作流并行调用云函数来并行处理任务，大大提高了任务处理的吞吐量，满足了应用场景的高实时性和并发性。

本期主要分享如何利用ASW的地图节点能力进行并发数据求和计算。

01。

创建一个函数

1.登录“云函数控制台”，创建一个云函数，函数名为Sum，运行环境Python 3.6。

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

# *编码:utf8 *

导入json

def mainhandler(事件，上下文):

总和= 0

对于事件中的I[值]:

总和+= i

返回总和

02。

创建工作流

1.登录应用与编排服务流程控制台，在工作流页面点击“新建”，进入创建工作流页面，点击“入门模板”，选择“映射周期”模板。

ASW中的Map节点将遍历输入中的数组类型参数，并为数组中的每个元素并行执行其串行节点。Map类似于编程语言中的foreach，但是节点循环任务是并发执行的。

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

2.在代码中修改迭代器下的States节点中的state01，以调用sum函数，如以下工作流中所定义:

{

注释:使用Map节点循环处理数组array中的数据，

StartAt: MapState，

国家:{

映射状态:{

类型:地图，

ItemsPath: $。数组，

结果路径:$。结果，

MaxConcurrency: 2，

接下来:FinalState，

迭代器:{

StartAt:状态01，

国家:{

状态01: {

类型:任务，

注释:调用求和函数，

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

结束:真的

}

}

}

},

最终状态:{

类型:通过，

结束:真的

}

ItemsPath指定一个作为Map节点循环的数组。

MaxConcurrency指定Map节点并发调用的函数数量。

迭代器是为Map节点的循环任务定义的。

3.单击下一步。在配置基本信息页面，输入工作流名称，选择运行角色和工作流类型，点击完成，完成工作流创建。

03。

运行工作流

1.在工作流列表中，点击“名称”链接进入工作流。在弹出的“开始执行”窗口中，输入JSON格式的数组array。例如:

{

数组:[{

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

},

{

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

},

{

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

},

{

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

}

]

}

2.单击“确定”。状态执行完成后，您可以在详细信息页面上查看执行结果。滑动到页面底部，在执行历史下，可以查看子节点的操作。我们可以看到Map节点会调用MaxConcurrency为2的sum函数，每个sum函数的参数都是数组array的一个项。

3.点击参考资料中的云函数链接，可以直接跳转到云函数控制台，查看函数执行的细节。

特别声明：以上文章内容仅代表作者本人观点，不代表ESG跨境电商观点或立场。如有关于作品内容、版权或其它问题请于作品发表后的30日内与ESG跨境电商联系。