函数流简介

组件说明

函数流提供多种类型的组件，用户可以通过拖拽组件、配置组件和连接组件进行可视化编排，实现函数任务流的编排。使用函数流功能，请先了解表1。

编排规则

• 设计的函数流必须是一个有向无环图，从开始节点出发，开始节点后续必须且只能连接一个节点（除了异常处理和结束节点）；流程必须在某一个节点结束，结束流程有两种形式：
  1. 流程中存在的节点没有任何后继节点，且后续节点非条件分支，并行分支或开始节点。
  2. 流程中存在结束节点，且结束节点后续无其他节点。
• 组件设计规则

  表2 触发器和函数和EG

  参数	说明	创建函数流时，是否必选
  触发器	当前允许流程中配置0-10个触发器。 触发器必须配置在开始节点内。 触发器不允许连接其他任何节点，也不允许被其他节点连接。	否
  函数	当前允许流程中配置0-99个函数节点。 当函数连接异常处理节点时，最多可以再连接一个非开始节点和非异常处理节点。 当函数不连接异常处理节点时，只能连接一个非开始节点。	否
  EG	当前允许流程中配置0-10个EG节点。 当EG节点连接异常处理节点时，最多可以再连接一个非开始节点和非异常处理节点。 当EG节点不连接异常处理节点时，只能连接一个非开始节点。	否

  表3 流程控制器

  参数	说明	创建函数流时，是否必选
  回调节点	回调节点限制规则参考表2中函数参数，但回调节点不可为服务节点的子节点	否
  子流程	该节点选择已创建的函数流任务。	否
  并行分支	用于标识节点后面的分支会并行执行。 后继节点允许连接1-20个节点（除了异常处理，开始节点和结束节点），至少连接一个节点。	否
  开始节点	用于标识流程开始，每个流程必须有且只能有一个开始节点。 开始节点后面必须接1个节点，后续节点类型不能是结束节点或者异常处理。	必选
  异常处理	后面可以接0-10个节点，后继节点不能是开始节点，结束节点和异常处理节点。	否
  循环节点	用来对数组中每个元素进行循环处理。每次循环会执行一次循环内部的子流程。 循环节点内部子流程需要满足如下规则： 只能有一个起始节点（没有前驱节点），起始节点只能使用函数，时间等待节点。 循环节点内部只允许编排函数，时间等待，异常处理节点。	否
  时间等待	后面可以连接0个或1个节点，节点类型不能是开始节点和异常处理节点。	否
  服务节点	服务节点由多个函数节点组成，后续节点可以是结束节点或异常处理节点。	否
  条件分支	后面可以连接2-20个后继节点，后继节点类型不能为开始节点，结束节点和异常处理节点。	否
  结束节点	后面不能接任何节点。	否

表达式运算符说明

异常处理和条件分支的表达式的结构为 [JsonPath] + [逻辑运算符] + [对比数据]，简单示例：$.age >= 20

JsonPath说明

参见示例

• 简单取值：JSON数据样例

  {  
       "fruits": [ "apple", "orange", "pear" ],  
       "vegetables": [{      
       "veggieName": "potato",
       "veggieLike": true    
        },     
        {       
            "veggieName": "broccoli",      
            "veggieLike": false    
        }] 
  }

  $.fruits表达式含义：取出fruits下对应的所有value。

  $.fruits解析结果：["apple","orange","pear"]

• 简单过滤：JSON数据样例

  {   
         "fruits": [ "apple", "orange", "pear" ],
         "vegetables": [{ 
         "veggieName": "potato",
         "veggieLike": true
         },     
        { 
            "veggieName": "broccoli",
            "veggieLike": false     
        }] 
  }

  表达式：$.vegetables[?(@.veggieLike == true)].veggieName

  表达式含义：取出key值vegetables对应的所有value，并根据过滤条件输出veggieLike为True的veggieName。

  取值结果：[potato]

逻辑运算符说明

使用以下数据作为例子中的输入参数：

{
  "name" : "apple",
  "weight": 13.4,
  "type": [3,4,6,8],
  "obj": {
        "a" : 1
   }
}

支持的运算符如下：

• 字符串格式常量需要使用‘’包含，例如：‘apple’
• jsonpath表达式中不能出现上述保留字符'=', '!=', '<', '>', '|', '&'

配置示例

示例一：并行分支使用参考

1. 新建三个函数， Runtime均使用python 3.9，代码功能及内容如下所示 。
   • 函数1：函数执行返回result的值为函数调用事件内的input输入值

     import json
     def handler (event, context):
         input = event.get('input',0)
         return {
             "result": input
             }

   • 函数2：函数执行返回result的值为函数调用事件内的input输入值+2的结果值

     import json
     def handler (event, context):
         input = event.get('input',0)
         return {
             "result": input+2
             }

   • 函数3：函数执行返回result的值为函数调用事件内的input输入值平方的结果值

     import json
     def handler (event, context):
         input = event.get('input',0)
         return {
             "result": input*input
             }

2. 在函数流编排区域拖拽组件，“并行分支”节点配置如下。
   图1 并行分支节点配置
   
3. 函数节点配置如表2 触发器和函数所示，在3个函数节点均需配置
   图2 函数节点配置
   
4. 保存函数流，启动执行时，定义输入值如下所示。

   {
     "input":3
   }

5. 单击函数流任务名称，查看执行结果。
   图3 执行结果
   

示例二：服务节点使用参考：串行模式

1. 在函数编排区域编排与拖拽组件，服务节点选择“串行模式”。
   图4 服务节点配置
   
2. 函数节点分别选择示例一中创建的函数2、函数3，函数流的配置如下。
   图5 函数2配置
   
   图6 函数3配置
   
3. 保存函数流，启动执行时，定义输入值如下所示。

   {
     "input":3
   }

4. 单击函数流任务名称，查看执行结果。
   图7 执行结果
   

示例四：异常处理使用参考

• 设计一个函数流：当输入值input<2时，执行子流程串行执行（输入值先加2再平方）；当输入值input=2，走默认分支，输出原值；当输入值input>2时，执行子流程并行执行（并行输出原值、输入值加2和输入值的平方值），具体如下：

• 输入3，走子流程并发，结果如下：

• 输入1，走子流程串行，结果如下：

• 输入2，走默认分支，输出原值，结果如下：

示例八：循环节点使用参考

使用“循环”组件来对输入数组中每个元素进行循环处理。每次循环会执行一次循环内部的子流程。

• 设计一个函数流，输入一个整数数组，通过循环对整数数组的每一个元素先加2再平方，具体实现如下：

  

• 配置遍历数组路径$.inputs，迭代变量名称$.item

  

• 函数-加2配置，函数参数配置中的Value要与“循环”里面的迭代变量名称一致：