调用函数

组件信息

操作概述

使用函数计算组件时，需要开通阿里云函数计算服务并在函数计算产品中配置、设计函数，总体操作大致分为3步：

1. 配置函数：在函数计算产品中配置函数。

2. 设计函数：在函数计算产品中设计函数。

3. 组件配置：配置流程中的调用函数组件，帮助您在流程中调用您在函数计算产品中的自定义函数，以实现自定义业务逻辑。

前提条件

已开通函数计算服务。

1. 创建并配置函数

您可以参考以下步骤创建并配置函数。

1. 进入函数计算控制台，点击左侧函数管理 > 函数列表页面，并在页面顶部选择地域，建议该地域与流程所在地域保持一致。

2. 在函数列表中点击创建函数 > 创建Web函数。

   1. 主要配置：函数代码 > 运行环境：选择合适的运行环境类型。下面示例将通过内置运行时 > Python > Python 3.10的函数进行介绍。

      

   2. 其余可按需配置。

2. 设计函数

直接使用流程编辑器的函数模板可以帮助您聚焦于自定义业务逻辑的实现，并快速部署一个简单可用的流程函数。

1. 在函数详情页面的代码页签中，将默认的index.py文件内容替换为下列模板内容。

   说明

   该部分内容是兼容流程调用逻辑的WSGI处理程序，不包含您的自定义业务逻辑，您无需修改此文件中的函数及其内容。

   

   import json
   from my import *
   
   # DO NOT CHANGE THIS ENTIRE FILE!
   
   # handle wsgi request
   # about wsgi: https://wsgi.readthedocs.io/en/latest/learn.html
   def handler(environ, start_response):
       # get request_body
       try:
           request_body_size = int(environ.get('CONTENT_LENGTH', 0))
       except ValueError:
           request_body_size = 0
   
       request_body = environ['wsgi.input'].read(request_body_size)
       print(request_body)
   
       # get path info
       path_info = environ['PATH_INFO']
       print(path_info)
   
       # load http triggering request to json
       # as flow node input args
       body = json.loads(request_body.decode('utf-8'))
   
       # do custom node process
       if path_info == '/handle_exec':
           output = handle_exec(body['variables'])
       elif path_info == '/handle_awake':
           output = handle_awake(
               body['asyncId'],
               body['async_event_data'],
               body['variables']
           )
       else:
           raise Exception('Invalid path ' + path_info)
   
       status = '200 OK'
       response_headers = [('Content-type', 'text/plain')]
       start_response(status, response_headers)
   
       return [json.dumps(output).encode('utf-8')]

2. 新建脚本文件my.py，将以下代码复制到my.py文件中。

import random


# impl: py spi handle_exec
def handle_exec(variables) -> dict:
    # translate fun request
    random_number_length = variables['random_number_length']

    random_number = generate_random_by_length(random_number_length)
    print("random generated as " + str(random_number))

    if (random_number % 2) == 0:
        number_type = "even"
    else:
        number_type = "odd"

    result = {
        'success': True,
        'message': 'OK',
        'await': False,
        'outputVariables': {
            'random': random_number,
            'type': number_type
        },
        'toBranchCode': number_type
    }

    return result


# impl: py spi handle_awake
def handle_awake(async_id, async_event_data, variables) -> dict:
    return {}


def generate_random_by_length(random_number_length) -> int:
    length = int(random_number_length)

    start = 10 ** (length - 1)
    stop = 10 ** length

    print("from " + str(start) + "(inclusive) to " + str(stop) + "(exclusive)")
    return random.randrange(start, stop)

无论您的自定义逻辑如何，my.py文件中下列两个函数是必须的。

无论您的自定义逻辑如何，上述两个函数的返回结构是固定的。

• success：标识了该次函数调用是否成功，如果失败，流程会抛出错误并终止运行。

• message：提示信息，可自定义。

• await：是否仍需等待后续事件处理（如果您在流程中配置了函数计算组件的事件处理），一般情况下无需进行事件处理。如果为False，流程会采纳下列输出变量和分支code进行下一步处理。

• outputVariables：输出至流程的变量名及其值，您可以在后续流程中引用这些变量。只有在await为False时才会被流程采纳。

• toBranchCode：输出至流程的分支code（如果您在流程中配置了函数计算组件的多分支），流程会根据您返回的分支code以及您在流程编辑器中的流程配置决定后续走向。只有在await为False时才会被流程采纳。

result = {
    'success': True,
    'message': 'OK',
    'await': False,
    'outputVariables': {
        'myVarExample1': 'a',
        'myVarExample2': 'b'
    },
    'toBranchCode': 'example'
}

3. 文件修改后，点击部署代码。

3. 组件配置

您可以参考以下操作，配置流程中的调用函数组件，帮助您在流程中调用您在函数计算产品中的自定义函数，以实现自定义业务逻辑。

1. 前提条件

   您可以通过已存在的流程或者创建新的流程进入流程的画布编排页面。

   • 进入已存在的流程画布编排页面

     在Chat App 消息服务控制台 > 流程编辑器 > 流程管理页签，单击需编辑的流程名称，进入流程的编排页面。

     

   • 创建新的流程进入画布编排页面。具体操作请参见创建流程。

2. 单击画布上的调用函数组件图标，查看右侧组件配置区域。

   

3. 根据需求配置组件数据，详细配置说明请参见配置项说明。

4. 配置完成后，单击保存，在弹出的对话框中单击保存，完成保存。

   

配置项说明