引言

1. Push to Edge 节点简介

2. 节点配置

2.1 基本配置示例

3. 使用场景

3.1 边缘计算

3.2 本地数据处理

3.3 实时响应

4. 实际项目中的应用

4.1 项目背景

4.2 项目需求

4.3 实现步骤

5. 总结

---

引言

ThingsBoard 是一个开源的物联网平台，提供了设备管理、数据收集、处理和可视化等功能。规则链是 ThingsBoard 中的一个强大功能，允许用户定义复杂的业务逻辑来处理设备上报的数据。在规则链中，Push to Edge 节点用于将数据推送到边缘设备，这对于实现边缘计算和本地数据处理非常有用。

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

1. Push to Edge 节点简介

Push to Edge 节点的主要作用是在规则链执行过程中将数据推送到边缘设备。通过 Push to Edge 节点，可以将处理后的数据发送到边缘设备，实现在边缘侧进行进一步的处理和决策。这在边缘计算、本地数据处理和实时响应中非常有用。

2. 节点配置

• Edge设备：选择目标边缘设备，可以是已经注册在ThingsBoard中的边缘设备。
• 消息类型：指定要发送的消息类型，常见的有 POST_TELEMETRY、RPC_CALL 等。
• 消息内容：设置要发送的消息内容，可以是静态值、动态表达式或消息中的属性。

2.1 基本配置示例

{
  "edge": "EdgeDevice1",
  "messageType": "POST_TELEMETRY",
  "data": {
    "temperature": "${msg.temperature}",
    "humidity": "${msg.humidity}"
  }
}

3. 使用场景

Push to Edge 节点在多种场景下都非常有用，特别是在需要实现边缘计算、本地数据处理和实时响应时。以下是一些具体的应用场景：

3.1 边缘计算

在边缘计算中，需要将部分数据处理任务从云端下放到边缘设备，以减少网络延迟和带宽消耗。

{
  "edge": "EdgeDevice1",
  "messageType": "POST_TELEMETRY",
  "data": {
    "temperature": "${msg.temperature}",
    "humidity": "${msg.humidity}"
  }
}

3.2 本地数据处理

在某些场景下，需要在边缘设备上进行本地数据处理，例如实时数据分析和异常检测。

{
  "edge": "EdgeDevice1",
  "messageType": "RPC_CALL",
  "method": "processData",
  "params": {
    "data": "${msg.data}"
  }
}

3.3 实时响应

在实时响应中，需要将处理后的数据快速推送到边缘设备，以便进行即时的控制和决策。

{
  "edge": "EdgeDevice1",
  "messageType": "RPC_CALL",
  "method": "controlDevice",
  "params": {
    "action": "turnOn"
  }
}

4. 实际项目中的应用

下面是一个实际项目中的例子，展示如何在智能工厂监控系统中使用 Push to Edge 节点。

4.1 项目背景

假设我们正在开发一个智能工厂监控系统，该系统需要实时监测生产线上的设备状态，并在边缘设备上进行本地数据处理和实时响应。此外，还需要将处理后的数据发送到云端进行进一步的分析和存储。

4.2 项目需求

• 监测生产线上的设备状态。
• 在边缘设备上进行本地数据处理和异常检测。
• 将处理后的数据发送到云端进行进一步的分析和存储。
• 实现实时响应，例如控制设备的开关状态。

4.3 实现步骤

1. 部署传感器：

   • 在生产线上安装传感器，实时采集设备状态数据。

2. 创建规则链：

   • 添加 Push to Edge 节点，将数据推送到边缘设备。
   • 添加其他处理节点，如数据处理、异常检测和数据存储。

3. 配置规则链：

   • 配置 Push to Edge 节点，将设备状态数据推送到边缘设备。

{
  "edge": "EdgeDevice1",
  "messageType": "POST_TELEMETRY",
  "data": {
    "temperature": "${msg.temperature}",
    "humidity": "${msg.humidity}",
    "pressure": "${msg.pressure}"
  }
}

• 配置 Push to Edge 节点，调用边缘设备上的RPC方法进行数据处理和异常检测。

{
  "edge": "EdgeDevice1",
  "messageType": "RPC_CALL",
  "method": "processData",
  "params": {
    "data": "${msg.data}"
  }
}

1. 处理数据：
   • 在边缘设备上进行本地数据处理和异常检测。
   • 如果检测到异常情况，立即采取措施，例如停止设备运行。

// 边缘设备上的RPC方法
public void processData(Map<String, Object> data) {
    double temperature = (double) data.get("temperature");
    double humidity = (double) data.get("humidity");
    double pressure = (double) data.get("pressure");

    if (temperature > 80 || humidity > 70 || pressure > 100) {
        // 检测到异常情况，立即停止设备运行
        stopDevice();
    }
}

1. 实时响应：
   • 根据处理结果，控制设备的开关状态。

{
  "edge": "EdgeDevice1",
  "messageType": "RPC_CALL",
  "method": "controlDevice",
  "params": {
    "action": "turnOn"
  }
}

1. 前端界面：

   • 开发一个前端界面，显示实时的设备状态和处理结果。
   • 提供一个界面，让用户能够查看和管理设备的开关状态。

2. 数据查询：

   • 使用 ThingsBoard 的 REST API 或 GraphQL 查询，获取历史数据和处理结果。

GET /api/plugins/telemetry/DEVICE/{deviceId}/values/timeseries?keys=temperature,humidity,pressure&startTs={startTimestamp}&endTs={endTimestamp}

5. 总结

Push to Edge 节点在 ThingsBoard 规则链中是一个非常有用的工具，可以帮助将数据推送到边缘设备，实现在边缘侧进行进一步的处理和决策。通过合理地使用 Push to Edge 节点，可以更好地管理和自动化系统中的各种操作。无论是在智能工厂、工业监控还是其他物联网应用中，Push to Edge 节点都能发挥重要作用。

 🌐 项目地址

Things Vuehttp://thingsvue.tpson.cn:7772/#/login?redirect=/tb-home/index

账号：admin@thingsboard.org 
密码：admin123456

🎽 安装使用

获取项目代码：

代码地址​https://gitee.com/tpsonwell_admin/thingsvue