在华为云Astro轻应用中调用流式报文接口实现智能助手聊天对话

1. 参考授权用户使用华为云Astro轻应用并购买实例中操作，申请华为云Astro轻应用免费试用或购买商业实例。
2. 实例购买后，在华为云Astro轻应用服务控制台的“主页”中，单击“进入首页”，进入应用开发页面。
3. 在“应用”中，单击“新建低代码应用”或单击，进入新建低代码应用页面。

   首次创建应用时，请根据界面提示创建一个命名空间。命名空间一旦创建，不能修改和删除，创建前请确认好相关信息。建议使用公司或团队的缩写作为命名空间。

4. 在新建低代码应用页面，应用类型选择“标准应用”，单击“确定”。
5. 输入应用的标签和名称，单击“新建”，即可进入应用设计器。
   图2 创建一个空白应用
   

   表2 新建空白应用参数说明

   参数	说明	示例
   标签	新建应用的标签，长度不能超过80个字符。标签是应用在系统中的唯一标识，创建后不支持修改。	我的第一个应用
   名称	新建应用的名称，输入标签值后单击该参数的输入框，系统会自动生成应用的名称，同时自动在名称前，添加命名空间__。命名要求如下： 长度不能超过31个字符，包括前缀命名空间的长度。 名称前的内容为命名空间，在华为云Astro轻应用中为了避免不同租户间数据的重名，租户在首次创建应用时需要先定义一个命名空间。一个租户只能创建一个命名空间，创建后不支持修改。 必须以英文字母开头，只能由英文字母、数字或单下划线组成，且不允许以下划线结尾。	A

本示例代码主要实现的功能包括：创建一个客户端，通过POST方法和GET方法调用相应的接口，使后台以处理流式报文的方式处理接口返回的数据。其中，https://example.com为待调用大模型接口的地址。

通过脚本直接调用SSE协议的URL时，传入参数“isStream”必须设置为“true”，否则不会走流式的处理逻辑。

import * as context from 'context';
import * as http from 'http';
/*
 * The input parameter is defined by `@action.param()`.
 */
export class Input {
    @action.param({ type: "String", required: true, description: "the operation type" })
    inputParam: string;
}
/*
 * The output parameter is defined by `@action.param()`.
 */
export class Output {
}
/*
 * Define the main service class.
 * 
 * - The service entry function is defined by `@action.method()`.
 * - All dependent objects should be defined via `@useObject([])` (for objects) or `@useBo([])` (for business objects).
 */
export class CallSseUrl {
    @action.method({ input: "Input", output: "Output", description: "do a operation" })
    run(input: Input): Output {
        let output = new Output();
        let cli = http.newClient()
        let resp = cli.post("https://example.com",
            { isStream: true, data: { "message": input.inputParam }, headers: { "Content-Type": "application/json" } })
        return output;
    }
}

1. 在脚本编辑器上方单击，进入脚本调试页面。
2. 在“输入参数”页签中，输入如下示例。
   图4 设置输入参数
   

   {
       "inputParam": "我想创建一个差旅管理应用"
   }

3. 单击，执行脚本。

   在“输出参数”中，输出如下流式内容，表明脚本输出正常。

   图5 脚本输出内容
   

   好的！为您**智能规划**了"**差旅管理**"应用的构建计划如下：
   1. 创建一个名为"**差旅管理**"的低代码应用；
   2. 添加模型对象"**差旅管理**"，包含字段：
      - **出发城市**（下拉选择）
      - **目的城市**（下拉选择）
      - **出发时间**（日期）
      - **结束时间**（日期）
      - **出差目的**（文本）
   3. 为"**差旅管理**"模型生成一个标准的**增删改查界面**；
   4. 配置一条脚本逻辑："**提交申请后，自动流转到审批人进行审核**"。
   请问您是否确认该构建计划？
   您可以输入：
   - "**确认**"，我将开始执行；
   - 或输入**修改意见**，例如"增加一个报销单模型"或"把交通工具改为文本字段"。

1. 参考授权用户使用华为云Astro轻应用并购买实例中操作，申请华为云Astro轻应用免费试用或购买商业实例。
2. 实例购买后，在华为云Astro轻应用服务控制台的“主页”中，单击“进入首页”，进入应用开发页面。
3. 在“应用”中，单击“新建低代码应用”或单击，进入新建低代码应用页面。

   首次创建应用时，请根据界面提示创建一个命名空间。命名空间一旦创建，不能修改和删除，创建前请确认好相关信息。建议使用公司或团队的缩写作为命名空间。

4. 在新建低代码应用页面，应用类型选择“标准应用”，单击“确定”。
5. 输入应用的标签和名称，单击“新建”，即可进入应用设计器。
   图6 创建一个空白应用
   

   表4 新建空白应用参数说明

   参数	说明	示例
   标签	新建应用的标签，长度不能超过80个字符。标签是应用在系统中的唯一标识，创建后不支持修改。	我的第一个应用
   名称	新建应用的名称，输入标签值后单击该参数的输入框，系统会自动生成应用的名称，同时自动在名称前，添加命名空间__。命名要求如下： 长度不能超过31个字符，包括前缀命名空间的长度。 名称前的内容为命名空间，在华为云Astro轻应用中为了避免不同租户间数据的重名，租户在首次创建应用时需要先定义一个命名空间。一个租户只能创建一个命名空间，创建后不支持修改。 必须以英文字母开头，只能由英文字母、数字或单下划线组成，且不允许以下划线结尾。	A

1. 在应用设计器中，选择“集成”，单击“连接器”下的“连接器实例”。
2. 在“类型”中，选择“自定义连接器”，进入自定义连接器页面。
3. 单击“+”，配置连接器信息，单击“保存”。
   图7 创建自定义连接器
   

   表5 自定义连接器参数说明

   参数	说明	示例
   标签	自定义连接器的标签，创建后可修改。 取值范围：1~64个字符。	流式连接器
   名称	自定义连接器的名称，名称是连接器在系统中的唯一标识，创建后不可修改。命名要求如下： 长度不能超过64个字符，包括前缀命名空间的长度。 标识前模糊掉的内容为命名空间，在华为云Astro轻应用中为了避免不同租户间数据的重名，租户在首次创建应用时需要先定义一个命名空间。一个租户只能创建一个命名空间，创建后不支持修改。 必须以英文字母开头，只能由英文字母、数字或单下划线组成，且不能以下划线结尾。	streamconnector

1. 在“动作”页签中，单击“新建”。
2. 设置动作的基本信息，单击“下一步”。
   图8 设置基本信息
   

   表6 动作基本信息参数说明

   参数	说明	示例
   标签	新建动作的标签名，用于在页面显示。 取值范围：1~64个字符。	streamaction
   名称	新建动作的名称，名称是动作在系统中的唯一标识。命名要求如下： 长度不能超过64个字符，包括前缀命名空间的长度。 标识前模糊掉的内容为命名空间，在华为云Astro轻应用中为了避免不同租户间数据的重名，租户在首次创建应用时需要先定义一个命名空间。一个租户只能创建一个命名空间，创建后不支持修改。 必须以英文字母开头，只能由英文字母、数字或单下划线组成，且不能以下划线结尾。	streamaction
   URL	待调用大模型接口的URL地址。	https://example.com
   方法	选择请求的方法，可以设置为POST或GET。	POST
   内容类型	输入内容的类型取决于第三方支持的具体种类，该类型在HTTP标准协议中定义。	application/json
   返回类型	选择接口的返回类型，支持“application/json”和“text/event-stream”两种类型。 application/json：选择该类型时，系统将忽略第三方实际返回的“Content-Type”，采用第三方配置的“Content-Type”来解析返回内容。 text/event-stream：选择该类型时，将以处理流式报文的方式处理接口返回值，需要确保第三方接口的返回值为流式报文，且响应体中的“Content-Type”为“text/event-stream”。	text/event-stream 注意： “返回类型”必须设置为“text/event-stream”，否则自定义连接器的执行逻辑不会走流式的处理逻辑。

3. 本示例无需设置消息头入参，请单击删除第一行参数，再单击“下一步”。
4. 设置输入参数，单击“下一步”。
   图9 输入参数配置页面
   

   表7仅介绍本实践中使用到的参数，其他参数解释请参见使用自定义连接器调用第三方接口。

   表7 输入参数说明

   参数	说明	示例
   标签	输入参数的标签名，用于在页面显示。	message
   名称	新建输入参数的名称，名称是输入参数在系统中的唯一标识。	message
   参数位置	设置输入参数的位置。	消息体
   数据类型	设置输入参数的数据类型，直接在下拉框中选择。	字符串

5. 本示例无需设置输出参数，请单击删除第一行参数，再单击“保存”。
6. 返回动作页签，单击该动作所在行的，启用该动作。
   图10 动作已启用
   

1. 在动作列表中，单击3中创建的动作，进入动作详情页。
2. 在动作详情页，单击页面上方的“测试”。
   图12 选择测试
   
3. 选择4中创建的认证信息，并设置输入参数，单击“测试”。
   图13 测试自定义连接器
   

   {
       "message": "我想创建一个差旅管理应用"
   }

   单击“测试”后，返回如下接口信息，表明自定义连接器创建成功。

   图14 接口返回信息
   

• 方式一：创建一个脚本，在脚本中调用自定义连接器。
  1. 参考通过脚本对接大模型接口中操作，创建一个空白脚本，在脚本编辑器中输入如下示例代码。其中，“命名空间__streamconnector”为2中创建连接器的名称，“命名空间__streamaction”为3中为连接器添加的动作，“命名空间__streamAuth”为4中为连接器添加的认证信息。

     import * as context from 'context';
     import * as connector from 'connector';
     
     
     /*
      * The input parameter is defined by `@action.param()`.
      */
     export class Input {
         @action.param({ type: "String", required: true, description: "the operation type" })
         inputParam: string;
     }
     
     /*
      * The output parameter is defined by `@action.param()`.
      */
     export class Output {
     }
     
     /*
      * Define the main service class.
      * 
      * - The service entry function is defined by `@action.method()`.
      * - All dependent objects should be defined via `@useObject([])` (for objects) or `@useBo([])` (for business objects).
      */
     export class CallCustomConnector{
     
         @action.method({ input: "Input", output: "Output", description: "do a operation" })
         run(input: Input): Output {
             let output = new Output();
     
             // 页面上自己创建的自定义连接器的调用方法，第一个参数是创建的自定义连接器名称，第二个参数是认证信息名称
             let client2 = connector.newClient("命名空间__streamconnector", "命名空间_streamAuth");
     
             let input2 = { "message": input.inputParam, "stream": true };
             // 第一个入参是动作名称， 第二个参数是入参
             let resp2 = client2.invoke("命名空间__streamaction", input2);
             context.getHttp().response.setBody(resp2.data)
             return output;
         }
     }

  2. 单击脚本编辑器上方的，保存脚本。
  3. 在脚本编辑器上方单击，调试脚本，调试方法请参考通过脚本对接大模型接口。
  4. 脚本校验符合预期后，单击脚本编辑器上方的，启用脚本。
• 方式二：创建一个服务编排，在服务编排调用自定义连接器。
  1. 在应用设计器中，选择“逻辑”，单击“编排”后的“+”。
  2. 输入服务编排的名称和标签，单击“添加”，进入服务编排页面。
     图15 创建服务编排
     

     表9 添加服务编排参数说明

     参数	说明	示例
     标签	新建服务编排的标签名，用于在界面展示，创建后可修改。 取值范围：1~64个字符。	流式编排
     名称	服务编排在系统中的唯一标识，创建后不支持修改。系统会自动在名称前添加“{命名空间}__”streamFlow，当其他功能调用服务编排时，调用的是服务编排的名称，而不是标签。 命名要求如下： 长度不能超过64个字符，包括前缀命名空间的长度。 名称前的内容为命名空间，在华为云Astro轻应用中为了避免不同租户间数据的重名，租户在首次创建应用时需要先定义一个命名空间。一个租户只能创建一个命名空间，创建后不支持修改。 名称必须以英文字母开头，只能由英文字母、数字或单下划线组成，且不能以下划线结尾。	streamFlow

  3. 在“连接器 > 自定义”中，拖拽4中连接器的认证信息到画布中。
     在服务编排中，如果包含多个图元，建议将流式自定义连接器图元置于服务编排的最后位置。若不将其置于最后，将无法获取到该图元之后其他图元的输出参数。

     图16 拖拽连接器到画布中
     
  4. 单击，进入全局上下文页面。
  5. 单击“变量”后的，新建message变量，类型为“文本”。
     图17 新建message变量
     
  6. 选中自定义连接器图元，单击，选择创建的动作。
     图18 选择动作
     
  7. 在“输入参数”中单击“新增行”，“目标”选择message，将6.e中创建的变量拖拽到“源”中。
     图19 设置输入参数
     
  8. 连接图元指定逻辑关系，即从开始图元连向连接器图元。
     图20 连接图元
     
  9. 单击页面上方的，保存服务编排。
  10. 单击页面上方的，启用服务编排。