ThingsBoard规则链节点：Script节点详解

news2024/10/25 1:33:08

引言

脚本节点简介

用法

含义

应用场景

实际项目运用示例

智能楼宇管理系统

工业自动化生产线

结论

引言

ThingsBoard是一个功能强大的物联网平台，它支持设备管理、数据收集与处理以及实时监控。其核心组件之一是规则引擎，允许用户定义复杂的业务逻辑来自动处理来自设备的数据流。本文将详细介绍规则链中的“脚本”（Script）节点，包括其基本用法、含义及在实际项目中的应用案例。

ThingsBoard从入门到实战课程，深入透析底层原理，快速搭建自己的IOT平台_哔哩哔哩_bilibiliThingsBoard从入门到实战课程，深入透析底层原理，快速搭建自己的IOT平台共计21条视频，包括：1、ThingsBoard项目介绍、2、ThingsBoard前端Vue版本代码编译、3、ThingsBoard本地后端源码编译等，UP主更多精彩视频，请关注UP账号。https://www.bilibili.com/video/BV1CH36egEDM/?spm_id_from=333.999.0.0&vd_source=5b535ac3589f53abe431d7f6afc44ff4

脚本节点简介

在ThingsBoard中，脚本节点提供了一种灵活的方式来执行自定义的JavaScript代码。这使得开发者能够实现更加复杂和定制化的数据处理逻辑，而不仅仅是依赖于预定义的节点功能。通过编写脚本，用户可以访问消息对象、上下文信息，并根据需要修改或生成新的消息。

用法

添加到规则链：在规则链编辑器界面，从左侧工具箱拖动“脚本”节点至右侧工作区。
配置选项：
- 脚本类型：选择脚本语言，默认为JavaScript。
- 脚本内容：在此处编写你的脚本代码。你可以访问msg对象（当前消息）、metadata（元数据）以及其他内置函数和变量。
连接到其他节点：通常该节点会放置在需要进行特定逻辑处理的地方，以便于后续处理步骤能够基于脚本处理后的结果继续操作。
查看结果：执行后，消息对象可能会被脚本修改，或者产生新的消息对象传递给下一个节点。

含义

脚本节点的主要作用是允许用户通过编程方式扩展规则链的功能。它可以用来实现任何预定义节点无法满足的需求，例如复杂的计算、条件判断、外部API调用等。

应用场景

复杂计算：当需要对遥测数据进行复杂的数学运算或统计分析时，使用脚本节点可以方便地实现这些计算。
动态路由：根据消息内容动态决定消息的流向，比如根据不同类型的报警级别将消息发送到不同的处理路径。
外部集成：与第三方服务进行交互，如调用REST API发送通知、查询数据库或与其他系统同步数据。
数据转换：对消息中的数据进行格式转换，以适应不同系统的接口要求。
条件判断：根据特定条件决定是否继续处理消息，或者改变消息的内容。

实际项目运用示例

智能楼宇管理系统

假设你正在开发一套智能楼宇管理系统，该系统集成了温度传感器、湿度传感器、安全摄像头等多种设备，用于监测楼宇内的环境状况并确保安全。

动态报警级别：当温度传感器检测到异常高温时，可以根据具体温度值动态设置报警级别。使用脚本节点编写如下脚本：
Javascript
深色版本
```
if (msg.temperature > 35) {
    msg.alarmLevel = 'CRITICAL';
} else if (msg.temperature > 30) {
    msg.alarmLevel = 'WARNING';
} else {
    msg.alarmLevel = 'NORMAL';
}
return { msg: msg, metadata: metadata, msgType: msgType };
```
这样，根据温度的不同，可以设置不同的报警级别，并且将这个级别作为新属性添加到消息中。

外部API调用：如果需要在检测到异常情况时向物业管理部门发送短信通知，可以通过脚本节点调用第三方短信服务API：

Javascript

深色版本

const http = require('http');
const options = {
    hostname: 'api.example.com',
    port: 80,
    path: '/send-sms',
    method: 'POST',
    headers: {
        'Content-Type': 'application/json'
    }
};

const req = http.request(options, res => {
    // Handle response
});

req.on('error', error => {
    // Handle error
});

const postData = JSON.stringify({
    phoneNumber: '+1234567890',
    message: `Temperature alarm at ${msg.location}: ${msg.temperature}°C`
});
req.write(postData);
req.end();

return { msg: msg, metadata: metadata, msgType: msgType };

工业自动化生产线

在一个工业自动化生产线上，各种传感器和控制器不断生成大量的操作日志和状态报告。这些数据对于维护生产线的正常运行至关重要。

数据清洗与转换：有时，从不同设备获取的数据格式可能不一致，需要统一格式后才能进行进一步处理。使用脚本节点可以实现数据格式的标准化：

Javascript

深色版本

if (msg.deviceType === 'temperatureSensor') {
    msg.value = msg.temperature;
    delete msg.temperature;
} else if (msg.deviceType === 'humiditySensor') {
    msg.value = msg.humidity;
    delete msg.humidity;
}

// Add a timestamp
msg.timestamp = new Date().toISOString();
return { msg: msg, metadata: metadata, msgType: msgType };

条件判断与控制：在某些情况下，可能需要根据特定条件触发某些操作。例如，当某台机器的故障计数超过阈值时，启动紧急停机程序：

Javascript

深色版本

if (msg.errorCount > 10) {
    // Trigger an emergency shutdown
    console.log(`Emergency shutdown triggered for device ${msg.deviceId}`);
    // Additional logic to handle the shutdown
}

return { msg: msg, metadata: metadata, msgType: msgType };