ThingsBoard规则链节点：AWS SQS 节点详解

🕗 发布于 2024-11-25 10:41 aws 云计算

引言

ThingsBoard 是一个开源的物联网平台，提供了设备管理、数据收集、处理和可视化等功能。规则链是 ThingsBoard 中的一个强大功能，允许用户定义复杂的业务逻辑来处理设备上报的数据。在规则链中，AWS SQS 节点用于将消息发送到 Amazon Simple Queue Service (SQS) 队列。

ThingsBoard从入门到实战课程，深入透析底层原理，快速搭建自己的IOT平台_哔哩哔哩_bilibiliThingsBoard从入门到实战课程，深入透析底层原理，快速搭建自己的IOT平台共计36条视频，包括：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

1. AWS SQS 节点简介

AWS SQS 节点的主要作用是在规则链执行过程中，将消息发送到 Amazon SQS 队列。Amazon SQS 是一种完全托管的消息队列服务，支持消息的异步传递，适用于解耦和分布式系统之间的通信。通过使用 AWS SQS 节点，可以将设备上报的数据或处理结果发送到 SQS 队列，再由其他服务或系统消费这些消息，实现异步处理和解耦。

2. 节点配置

AWS 区域：选择 AWS 服务所在的区域。
访问密钥：提供 AWS 访问密钥，用于身份验证。
秘密密钥：提供 AWS 秘密密钥，用于身份验证。
队列 URL：指定要发送消息的 SQS 队列的 URL。
消息：指定要发送的消息内容，可以是静态文本或动态变量。

2.1 基本配置示例

{
  "region": "us-east-1",
  "accessKey": "YOUR_ACCESS_KEY",
  "secretKey": "YOUR_SECRET_KEY",
  "queueUrl": "https://sqs.us-east-1.amazonaws.com/123456789012/YourQueueName",
  "message": "This is a test message from ThingsBoard"
}

3. 使用场景

AWS SQS 节点在多种场景下都非常有用，特别是在需要实现异步处理和解耦的场景中。以下是一些具体的应用场景：

3.1 数据处理

在需要将设备上报的数据异步处理时，可以通过 AWS SQS 节点将数据发送到 SQS 队列，再由其他服务或系统消费这些消息进行处理。

{
  "region": "us-east-1",
  "accessKey": "YOUR_ACCESS_KEY",
  "secretKey": "YOUR_SECRET_KEY",
  "queueUrl": "https://sqs.us-east-1.amazonaws.com/123456789012/DataProcessingQueue",
  "message": "Device ${msg.deviceId} reported data: ${msg.data}"
}

3.2 任务调度

在需要调度任务时，可以通过 AWS SQS 节点将任务消息发送到 SQS 队列，再由任务调度系统消费这些消息执行任务。

{
  "region": "us-east-1",
  "accessKey": "YOUR_ACCESS_KEY",
  "secretKey": "YOUR_SECRET_KEY",
  "queueUrl": "https://sqs.us-east-1.amazonaws.com/123456789012/TaskSchedulingQueue",
  "message": "Task scheduled for device ${msg.deviceId}: ${msg.taskDetails}"
}

3.3 事件通知

在需要发送事件通知时，可以通过 AWS SQS 节点将事件消息发送到 SQS 队列，再由事件处理系统消费这些消息进行通知。

{
  "region": "us-east-1",
  "accessKey": "YOUR_ACCESS_KEY",
  "secretKey": "YOUR_SECRET_KEY",
  "queueUrl": "https://sqs.us-east-1.amazonaws.com/123456789012/EventNotificationQueue",
  "message": "Event occurred for device ${msg.deviceId}: ${msg.eventType}"
}

4. 实际项目中的应用

下面是一个实际项目中的例子，展示如何在智能家居系统中使用 AWS SQS 节点。

4.1 项目背景

假设我们正在开发一个智能家居系统，该系统需要支持用户通过手机应用控制家中的灯光、空调等设备，并记录设备的状态和使用情况。此外，还需要实现数据处理、任务调度和事件通知功能。

4.2 项目需求

记录设备的状态，例如当前温度、湿度等。
记录设备的使用情况，例如开关次数、能耗等。
实现实时反馈，确保用户能够及时了解操作结果。
将设备上报的数据异步处理。
调度定期任务，例如定时开关设备。
发送事件通知，例如设备故障通知。

4.3 实现步骤

部署设备：
- 在家中安装智能灯光、空调等设备，并连接到 ThingsBoard 平台。
创建规则链：
- 添加 AWS SQS 节点，用于将设备上报的数据发送到 SQS 队列，再由其他服务或系统消费这些消息进行处理。
- 添加其他处理节点，如设备控制、状态查询和数据存储。
配置规则链
- 配置 AWS SQS 节点，用于发送数据处理消息。

{
  "region": "us-east-1",
  "accessKey": "YOUR_ACCESS_KEY",
  "secretKey": "YOUR_SECRET_KEY",
  "queueUrl": "https://sqs.us-east-1.amazonaws.com/123456789012/DataProcessingQueue",
  "message": "Device ${msg.deviceId} reported data: ${msg.data}"
}

配置 AWS SQS 节点，用于发送任务调度消息。

{
  "region": "us-east-1",
  "accessKey": "YOUR_ACCESS_KEY",
  "secretKey": "YOUR_SECRET_KEY",
  "queueUrl": "https://sqs.us-east-1.amazonaws.com/123456789012/TaskSchedulingQueue",
  "message": "Task scheduled for device ${msg.deviceId}: ${msg.taskDetails}"
}

配置 AWS SQS 节点，用于发送事件通知消息。

{
  "region": "us-east-1",
  "accessKey": "YOUR_ACCESS_KEY",
  "secretKey": "YOUR_SECRET_KEY",
  "queueUrl": "https://sqs.us-east-1.amazonaws.com/123456789012/EventNotificationQueue",
  "message": "Event occurred for device ${msg.deviceId}: ${msg.eventType}"
}

处理数据：
- 根据业务逻辑，动态地发送数据处理、任务调度和事件通知消息。

// 发送数据处理消息
public void sendDataProcessingMessage(String deviceId, String data) {
    // 配置 AWS SQS 节点
    JsonNode config = JsonNodeFactory.instance.objectNode()
        .put("region", "us-east-1")
        .put("accessKey", "YOUR_ACCESS_KEY")
        .put("secretKey", "YOUR_SECRET_KEY")
        .put("queueUrl", "https://sqs.us-east-1.amazonaws.com/123456789012/DataProcessingQueue")
        .put("message", "Device " + deviceId + " reported data: " + data);

    awsSqsNode.sendMessage(config);
}

// 发送任务调度消息
public void sendTaskSchedulingMessage(String deviceId, String taskDetails) {
    // 配置 AWS SQS 节点
    JsonNode config = JsonNodeFactory.instance.objectNode()
        .put("region", "us-east-1")
        .put("accessKey", "YOUR_ACCESS_KEY")
        .put("secretKey", "YOUR_SECRET_KEY")
        .put("queueUrl", "https://sqs.us-east-1.amazonaws.com/123456789012/TaskSchedulingQueue")
        .put("message", "Task scheduled for device " + deviceId + ": " + taskDetails);

    awsSqsNode.sendMessage(config);
}

// 发送事件通知消息
public void sendEventNotificationMessage(String deviceId, String eventType) {
    // 配置 AWS SQS 节点
    JsonNode config = JsonNodeFactory.instance.objectNode()
        .put("region", "us-east-1")
        .put("accessKey", "YOUR_ACCESS_KEY")
        .put("secretKey", "YOUR_SECRET_KEY")
        .put("queueUrl", "https://sqs.us-east-1.amazonaws.com/123456789012/EventNotificationQueue")
        .put("message", "Event occurred for device " + deviceId + ": " + eventType);

    awsSqsNode.sendMessage(config);
}

前端界面：
- 开发一个前端界面，显示设备的状态和使用情况。
- 提供一个界面，让用户能够查看和管理设备的状态和使用情况，以及接收通知。
数据查询：
- 使用 SQL 查询，获取设备的状态和使用情况。

SELECT * FROM device_status WHERE device_id = 'device1' ORDER BY timestamp DESC LIMIT 10;
SELECT * FROM device_usage WHERE device_id = 'device1' ORDER BY timestamp DESC LIMIT 10;

5. 总结

AWS SQS 节点在 ThingsBoard 规则链中是一个非常有用的工具，可以帮助你将消息发送到 Amazon SQS 队列，实现异步处理和解耦。通过合理地使用 AWS SQS 节点，可以在数据处理、任务调度和事件通知等场景中，确保系统的高效性和灵活性。

🌐 项目地址

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

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

🎽 安装使用

获取项目代码：

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

原文地址：https://blog.csdn.net/2401_85648342/article/details/143977650

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：STM32-- 串口发送数据
下一篇：【STM32】GPIO(超详细)

《图像形态学运算全解析：原理、语法及示例展示》
简介：本文详细介绍了图像形态学中的多种运算，包括腐蚀、膨胀、开运算、闭运算、形态学梯度运算、礼帽运算以及黑帽运算。分别阐述了各运算的原理、语法格式，并通过 Python 代码结合具体示例图片（如er
阅读更多2024-11-25
大连环保公益管理系统｜Java｜SSM｜Vue｜前后端分离
2⃣️：管理端：首页、个人中心、用户管理、用户环保币管理、环保币入账管理、环保币扣减管理、商品兑换管理、加入环保社团管理、活动报名管理、众筹支持管理、环保活动管理。4⃣️：环保社团端：首页、个人中心、
阅读更多2024-11-25
微信小程序条件渲染与列表渲染的全面教程
在微信小程序的开发中，条件渲染和列表渲染是构建动态用户界面的重要技术。通过条件渲染，我们可以根据不同的状态展示不同的内容，而列表渲染则使得我们能够高效地展示一组数据。本文将详细讲解这两种渲染方式的用法
阅读更多2024-11-25
docker基础命令
docker基础命令
阅读更多2024-11-25
【FPGA开发】Vivado自定义封装IP核，绑定总线
一般xilinx官方的bd中涉及的总线，都会可以直接映射的选，如果是自己定义的总线协议，也可以增加自定义。想把连接ram的端口绑定在一起，这样在BD中连线时，就不用一根根的拉线，就可以一个总线搞定。在
阅读更多2024-11-25
MATLAB 批量读取endnote导出的参考文献
endnote中有很多分组文件夹，如果批量导出。
阅读更多2024-11-25
实验二系统响应及系统稳定性
（1）学会运用Matlab 求解离散时间系统的零状态响应；（2）学会运用Matlab 求解离散时间系统的单位取样响应；（3）学会运用Matlab 求解离散时间系统的卷积和。
阅读更多2024-11-25
Spring：AOP切入点表达式
对于AOP中切入点表达式，我们总共会学习三个内容，分别是语法格式通配符和书写技巧。
阅读更多2024-11-25
【JavaEE进阶】 JavaScript
创建数组有两种⽅式1. 使⽤ new 关键字创建// Array 的 A 要⼤写2. 使⽤字⾯量⽅式创建 [常⽤]// 数组中保存的内容称为 "元素"注意: JS 的数组不要求元素
阅读更多2024-11-25
Java SE 与 Java EE：基础与进阶的探索之旅
Java SE 是 Java 的标准版，它提供了 Java 语言的基础、JDBC 数据库连接操作、I/O 流操作、网络通信、多线程等技术。Java SE 是 Java 平台的基础，用于开发和部署桌面、
阅读更多2024-11-25