关于腾讯云:ASW-工作流最佳实践二使用-ASW-并发调用函数

在音视频转码、ETL 作业处理、基因数据处理等诸多场景中，咱们都能够通过工作流并行调用云函数，将工作进行并行处理，大大提高工作解决的吞吐量，满足利用场景的高实时性、高并发能力。

在《应用 ASW 工作流创立您的第一个函数编排》文章中，咱们分享了如何应用 ASW 编排一个 Sum 云函数进行求和计算。本期文章次要分享如何应用 ASW 的 Map 节点能力进行并发的数据求和计算。

云函数控制台地址：https://console.cloud.tencent.com/scf

# -*- coding: utf8 -*-
import json 
def main_handler(event, context):
    sum = 0
    for i in event["values"]:
        sum += i
    return sum

ASW 中 Map 节点会遍历输出中的某个数组类型参数，对于数组中的每个元素并行执行其串行节点。Map 节点相似于编程语言中的 foreach，但节点循环工作是并发执行的。
ASW 控制台地址：https://console.cloud.tencent.com/asw

批改「代码」中 Iterator 下 States 节点中的 state01 为 sum 函数调用，如下工作流定义：

{
 "Comment": "应用 Map 节点循环解决数组 array 中的数据",
 "StartAt": "MapState",
 "States": {
  "MapState": {
   "Type": "Map",
   "ItemsPath": "$.array",
   "ResultPath": "$.result",
   "MaxConcurrency": 2,
   "Next": "FinalState",
   "Iterator": {
    "StartAt": "State01",
    "States": {
     "State01": {
      "Type": "Task",
      "Comment": "调用求和函数",
      "Resource": "qrn:qcs:asw:ap-guangzhou:123456789:sdk:json:qcloud:scf:Invoke/sum/$DEFAULT/default",
      "End": true
     }
    }
   }
  },
  "FinalState": {
   "Type": "Pass",
   "End": true
}

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

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

Iterator 为 Map 节点循环工作定义。

单击「下一步」，在「配置根本信息」页面，输出工作流名称，抉择运行角色与工作流类型，单击「实现」，实现工作流创立。

在工作流列表，单击「名称」链接进入工作流，您在弹出的「开始执行」窗口中，以 JSON 格局输出 array 数组。例如：

{
 "array": [{"values": [1, 2, 3, 4, 5]
  },
  {"values": [4, 2, 3, 1, 5]
  },
  {"values": [1, 0, 8, 4, 5]
  },
  {"values": [7, 2, 3, -2, 5]
  }
 ]
}

单击「确定」，实现状态执行后，能够在详情页查看执行后果。滑动至页面最下方，在「执行历史记录」下，您能够查看子节点的运行状况。咱们能够看到 Map 节点会以并发数（MaxConcurrency）为 2 来调用 sum 函数，每个 sum 函数的入参为 array 数组的一个 item。

单击「资源」中的云函数链接，能够间接跳到云函数控制台，查看函数执行详情。

辨认下方 👇 二维码，即可退出腾讯云 ASW 交换群。

立刻体验腾讯云 Serverless Demo，支付 Serverless 新用户礼包 👉 腾讯云 Serverless 老手体验。

关于腾讯云:ASW-工作流最佳实践二使用-ASW-并发调用函数

01. 创立函数

02. 创立工作流

03. 运行工作流

One More Thing