jsTransform组件：脚本转换器。可以使用JavaScript脚本对msg、metadata、msgType进行转换或增强。然后把转换后的消息交给下一个节点。

JavaScript脚本支持ECMAScript 5.1(+) 语法规范和部分ES6规范，如：async/await/Promise/let。允许在脚本中调用Go自定义函数，请参考udf 。

配置

字段	类型	说明	默认值
jsScript	string	js脚本	无

• jsScript：可以对msg、metadata、msgType进行转换或增强。该字段是以下函数体内容

      function Transform(msg, metadata, msgType) { 
          ${jsScript} 
       }
  

  • msg：消息内容，如果dataType=JSON,类型是：jsonObject ，可以使用msg.temperature 方式操作。如果dataType是其他类型，该字段类型是:string
  • metadata：消息元数据，类型：jsonObject
  • msgType：消息类型
  • 函数返回值类型：{'msg':msg,'metadata':metadata,'msgType':msgType};

注意

脚本执行超时时间配置参考： config.ScriptMaxExecutionTime

Relation Type

• Success: 执行成功，把消息发送到Success链
• Failure: 执行失败，把消息发送到Failure链

执行结果

通过脚本改变 msg、metadata和msgType内容。

配置示例

  {
    "id": "s1",
    "type": "jsTransform",
    "name": "转换",
    "configuration": {
      "jsScript": "metadata['name']='test01';\n metadata['index']=11;\n msg['addField']='addValue1'; return {'msg':msg,'metadata':metadata,'msgType':msgType};"
    }
  }

应用示例

把消息进行转换后再执行后续逻辑。

{
  "ruleChain": {
    "id":"rule01",
    "name": "测试规则链",
    "root": true
  },
  "metadata": {
    "nodes": [
       {
        "id": "s1",
        "type": "jsTransform",
        "name": "转换",
        "configuration": {
          "jsScript": "metadata['name']='test02';\n metadata['index']=22;\n msg['addField']='addValue2'; return {'msg':msg,'metadata':metadata,'msgType':msgType};"
        }
      },
      {
        "id": "s2",
        "type": "restApiCall",
        "name": "推送数据",
        "configuration": {
          "restEndpointUrlPattern": "http://192.168.136.26:9099/api/msg",
          "requestMethod": "POST",
          "maxParallelRequestsCount": 200
        }
      }
    ],
    "connections": [
      {
        "fromId": "s1",
        "toId": "s2",
        "type": "Success"
      }
    ]
  }
}