自定义函数实现 IoT 设备数据解码和实时告警通知

为了增强规则引擎数据处理能力，EMQX Cloud 推出了「自定义函数」增值服务。

用户可以通过编写基于 ECMAScript 5.1 及部分 ECMAScript 6 的语法的自定义脚本实现数据处理逻辑，并在 EMQX Cloud 规则引擎中调用，这样就可以完成更加复杂的数据预处理逻辑，并通过规则引擎将函数返回的数据按业务需求流转至消息消费方。

* 注：考虑到执行性能对整体消息吞吐性能的影响，EMQX Cloud 提供的自定义函数会对执行脚本进行性能检查，脚本执行时间不能超过 3 秒，否则将无法通过验证。因此我们不建议在脚本中编写高耗时的操作。

在设备数据上报场景中，对于网络带宽受限以及功耗敏感的设备，在数据传输过程中往往会将设备数据通过更加紧凑的十六进制格式进行传输，以便节省带宽和功耗。在平台侧，如果业务应用需要理解上报数据的具体业务意义，则需根据规约将十六进制报文解析成 JSON 格式报文，方便应用开发。

示例

平台需要接入一个智能井盖设备，井盖设备需要定时上传 4 个传感器数据，设备通过十六进制数格式上报到平台，每两个字节代表一个传感器数据：

我们通过自定义函数将十六进制数转换为有意义的 JSON 格式，方便后台业务应用对数据进行消费。我们在 EMQX Cloud 中创建一个自定义函数：

假如此时设备上报数据为 00011601，Payload 作为入参进入自定义函数输入为 { 0x00, 0x01, 0x16, 0x01}；我们以此输入测试函数输出，可以看到结果如下：

这样我们就可以通过自定义函数，将设备上报的编码数据格式转化为更为易处理的 JSON 格式供后端业务应用消费。

在设备数据上报过程中，数据上传通常会以比较简单的格式进行传输，比如会按默认规定省略一些默认的数据与格式。但对于平台侧应用来说，一般需要能够通过数据处理补齐相关的数据以达成数据格式的标准化。此时我们可以通过自定义函数来实现数据格式补齐。

示例

我们在办公楼的机房内部署了温湿度传感器以用来检测环境数据，传感器通过 MQTT 协议以 JSON 格式的Payload 上报报文到云端平台。数据报文格式如下：

{  "hum" : 20.0,  "temp" : 36.5}

我们希望通过自定义函数对每个上报报文进行单位的补齐，这时可以通过定义如下函数来实现：

通过函数测试我们可以看到，输出的数据被添加了相应的单位格式：

这样，我们就完成了对上报报文的格式转换工作。