跳到主要内容
版本：2.0.18

脚本引擎

FluxMQ支持脚本来处理数据流，可以将MQTT传输的Payload转换成任意格式，再流转到后续的规则引擎中，但是脚本中的方法尽量保持轻量、高效，避免出现阻塞Pipeline的情况。导致系统性能下降

在payload的json数据中，添加一个额外的字段​

JS脚本​

img.png

 function convert(topic, payload){
    var jsonString = JSON.stringify(payload);
    var jsonObject = JSON.parse(jsonString);
    jsonObject["additionalField"]="js";
    return JSON.stringify(jsonObject);
}

Groovy脚本​

img_1.png

import groovy.json.JsonSlurper
import groovy.json.JsonOutput
String  convert(String topic, byte[] payload){
    def jsonString = new String(payload, "UTF-8")
    def jsonObject = new JsonSlurper().parseText(jsonString)
    jsonObject.put("additionalField", "additionalField")
    return JsonOutput.toJson(jsonObject)
}

Lua脚本​

img.png

function convert(topic, payload){
    return payload;
}