对接ROMA Connect

背景信息

应用与数据集成平台（ROMA Connect）是一个全栈式的服务平台，聚焦应用和数据连接，提供数据（跨机房、跨数据中心、跨云的数据）、服务API（将数据和后端服务以API形式开放）、消息（为企业提供跨网络访问的安全、标准化消息通道）和设备信息（使用MQTT标准协议连接设备，帮助企业快速、简单地实现设备云端管理）集成能力，帮助企业快速联接云上云下，消除数字鸿沟，实现数字化转型。

AstroZero通过连接器和ROMA Connect对接后，可调用ROMA Connect的API，从而集成服务。

AstroZero提供了默认对接的ROMA Connect服务器，也支持对接通过华为云开通的自有ROMA Connect实例控制台，即参考配置ROMA Connect中操作，在AstroZero管理中心配置对接信息，并请从华为云控制台登录自有ROMA Connect实例。

前提条件

本章节以AstroZero对接自有ROMA Connect为例进行说明，默认对接的ROMA Connect服务器配置类似。

• 已在ROMA Connect平台上完成应用创建（创建时，应用的“Key”字符长度必须小于60，否则后续向AstroZero同步时会失败）、函数API创建、API分组创建、API创建、调试、发布和授权操作。关于ROMA Connect的具体操作，请参见使用ROMA Connect集成服务与配置API授权。

  例如，如图1所示，已在ROMA Connect平台创建“人员管理”应用。如图2所示，已发布“获取人员信息”API，且该API已授权给“人员管理”应用。

  图1 集成应用
  
  图2 授权API
  
• 已在ROMA Connect上，设置“app_secret”和“app_route”值为“on”。

  修改方法：在ROMA Connect实例控制台的“实例信息”页面，选择“配置参数”。修改“app_secret”和“app_route”的“参数运行值”为“on”。

在AstroZero上调用ROMA Connect的API

在ROMA Connect上创建的应用和发布的API，可以直接同步到AstroZero。通过AstroZero的ROMA Connect类型连接器，可在服务编排或脚本中调用ROMA Connect的API。

在服务编排中调用ROMA Connect的API

1. 参考如何开发服务编排中操作，创建一个服务编排。
2. 在服务编排设计页面左侧，选择“连接器 > ROMA”，拖拽“人员管理”（连接器名称为ROMA应用名称）图元至画布中。
   图10 拖拽连接器图元到画布中
   

3. 参考表1，设置变量和服务编排的输入输出参数。
   1. 选中开始图元，在服务编排设计页面右侧，选择。
   2. 在私有结构体页面，单击“新增”。
      创建输出参数结构体类型变量前，首先需要创建私有结构体类型。

      图11 添加私有结构体类型
      
   3. 新增一个空的私有结构体“retJson”，不用设置结构体成员。
      图12 新建私有结构体
      
   4. 在服务编排设计页面右侧，选择。
   5. 在全局上下文页面，单击“对象变量”后的加号。
      图13 添加对象变量
      
   6. 选择“私有结构体”，设置页面参数，名称为“retJson”，结构体选择已创建的私有结构体“retJson”。
      图14 配置私有结构体变量
      

   7. 参照上述操作，新增“out”私有结构体变量，结构体选择创建的私有结构体“out”。
      图15 对象out对象变量
      
   8. 在服务编排设计页面右侧，选择。
   9. 在全局上下文页面，单击“变量”后的加号，新增图17中两个变量。
      图16 创建变量
      
      图17 添加两个变量
      
   10. 单击工作区域开始图元或空白区域，在服务编排设计页面右侧，选择，设置该服务编排的入参和出参。
       图18 设置服务编排的入参和出参
       
   11. 参考配置系统参数中操作，新建系统参数“appkey”，值填写为ROMA应用的请求密钥。

       由于“X-HW-APPKEY”为ROMA应用的请求密钥，可能发生变化，您可以新建系统参数，加密存储此入参，并通过公式引用。当请求密钥变化时，修改系统参数即可。

       图19 新建系统参数appkey
       
   12. 在服务编排设计页面右侧，选择。
   13. 在全局上下文页面，单击“公式”后的加号，新建公式变量“appkey”，表达式为“SYSPARAMETER("appkey")”。
       图20 新建公式变量
       

4. 在“连接器”页面进行配置，“动作”选择具体调用的API，例如“获取人员信息”，根据表1配置入参和出参，并连接图元。
   图21 设置动作连接图元
   
   • 动作：具体调用的API，API选项由2.d同步而来。
   • 输入参数：调用API的输入参数。
   • 输出参数：调用API的输出参数。

5. 单击服务编排页面上方的，保存服务编排。
6. 保存成功后，单击编辑器页面上方的，执行服务编排。
7. 设置如下输入参数，单击“运行”。

   输入参数样例如下：

   {
       "userid": "001"
   }

   若显示如下信息，表示成功调用ROMA Connect的API。

   {
     "interviewId": "002N000000cOeh5XCDrc",
     "outputs": {
       "out": {
         "retCode": "0",
         "retJSON": {
           "result": {
             "employ_name": "zhangsan",
             "employ_no": "00xxxxxx"
           }
         }
       },
       "retCode": "0",
       "retJson": {
         "result": {
           "employ_name": "zhangsan",
           "employ_no": "00xxxxxx"
         }
       }
     }
   }

在脚本中调用ROMA Connect的API

1. 参考脚本开发实例中操作，创建一个脚本。
2. 在脚本编辑器中，输入如下脚本。

   // Here's your code.
   import * as roma from "roma";
   import * as sys from "sys";
   // 通过ROMA应用名创建client，第二个参数可以不填写, roma.newClient("人员管理");
   let client1 = roma.newClient("人员管理", roma.NameType.AppName)
   
   // 通过ROMA应用的APPID创建client
   let client2 = roma.newClient("com.appcube.user", roma.NameType.AppId)
   
   //通过API名称调用，第一个参数是API名称，入参在第二个参数中传入，$body可以传入body参数
   let resp1 = client1.sendRest("获取人员信息", {
       "X-HW-APPKEY": sys.getParameter("appkey"),
       "X-HW-ID": "com.appcube.user",
       userID: "1110000",
       $body: {}
   });
   console.log(resp1.$out)
   
   //通过API的URL调用，第一个参数是请求方法，第二个参数为接口URL，入参在第三个参数中传入，$body可以传入body参数
   let resp2 = client1.sendRestByURL("GET", "/getUserInfo", {
       "X-HW-APPKEY": sys.getParameter("appkey"),
       "X-HW-ID": "com.appcube.user",
       userID: "1110000",
       $body: {}
   });
   console.log(resp2.$out)

3. 单击脚本编辑器页面上方的，保存脚本。
4. 保存成功后，单击编辑器页面上方的，执行脚本。
5. 脚本中已设置输入参数，请直接单击测试窗口右上角的，执行脚本。
   日志页签显示如下信息，表示成功调用ROMA Connect的API。

   0813 16:33:31.504|debug|vm[2]>>> app cube 1.2.12 8fce52d0 2020-07-17 10:14:41 +0800 debug
   0813 16:33:31.504|debug|vm[2]>>> node: 1
   0813 16:33:31.504|debug|vm[2]>>> script: gongzhen10__roma 1.0.1 
   0813 16:33:31.504|debug|vm[2]>>> locale: zh_CN
   0813 16:33:31.504|debug|vm[2]>>> timezone: Local
   0813 16:33:31.723|debug|vm[2]>>> { retCode: '0', retJSON: { result: { employ_name: 'zhangsan', employ_no: '00xxxxxx' } } } (gongzhen10__roma.ts:17)
   0813 16:33:31.773|debug|vm[2]>>> { retCode: '0', retJSON: { result: { employ_name: 'zhangsan', employ_no: '00xxxxxx' } } } (gongzhen10__roma.ts:26)