Chat App Message Service：調用函數

組件資訊

操作概述

使用Function Compute組件時，需要開通阿里雲Function Compute服務並在Function Compute產品中配置、設計函數，總體操作大致分為3步：

1. 配置函數：在Function Compute產品中配置函數。

2. 設計函數：在Function Compute產品中設計函數。

3. 組件配置：配置流程中的調用函數組件，協助您在流程中調用您在Function Compute產品中的自訂函數，以實現自訂商務邏輯。

前提條件

已開通Function Compute服務。

1. 建立並配置函數

您可以參考以下步驟建立並配置函數。

1. 進入Function Compute控制台，點擊左側函數管理 > 函數列表頁面，並在頁面頂部選擇地區，建議該地區與流程所在地區保持一致。

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：是否仍需等待後續事件處理（如果您在流程中配置了Function Compute組件的事件處理），一般情況下無需進行事件處理。如果為False，流程會採納下列輸出變數和分支code進行下一步處理。

• outputVariables：輸出至流程的變數名及其值，您可以在後續流程中引用這些變數。只有在await為False時才會被流程採納。

• toBranchCode：輸出至流程的分支code（如果您在流程中配置了Function Compute組件的多分支），流程會根據您返回的分支code以及您在流程編輯器中的流程配置決定後續走向。只有在await為False時才會被流程採納。

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

3. 檔案修改後，點擊部署代碼。

3. 組件配置

您可以參考以下操作，配置流程中的調用函數組件，協助您在流程中調用您在Function Compute產品中的自訂函數，以實現自訂商務邏輯。

1. 前提條件

   您可以通過已存在的流程或者建立新的流程進入流程的畫布編排頁面。

   • 進入已存在的流程畫布編排頁面

     在Chat App Message Service控制台 > 流程編輯器 > 流程管理頁簽，單擊需編輯的流程名稱，進入流程的編排頁面。

     

   • 建立新的流程進入畫布編排頁面。具體操作請參見建立流程。

2. 單擊畫布上的調用函數元件圖表標，查看右側組件配置地區。

   

3. 根據需求配置組件資料，詳細配置說明請參見配置項說明。

4. 配置完成後，單擊儲存，在彈出的對話方塊中單擊儲存，完成儲存。

   

配置項說明