网站改成响应式,html5模板,做网站公司做网站公司,建网站需要什么资料目录 引言
1. GCP Pub/Sub 节点简介
2. 节点配置
2.1 基本配置示例
3. 使用场景
3.1 数据传输
3.2 数据分析
3.3 事件通知
3.4 任务调度
4. 实际项目中的应用
4.1 项目背景
4.2 项目需求
4.3 实现步骤
5. 总结 引言 ThingsBoard 是一个开源的物联网平台#xff0…目录 引言
1. GCP Pub/Sub 节点简介
2. 节点配置
2.1 基本配置示例
3. 使用场景
3.1 数据传输
3.2 数据分析
3.3 事件通知
3.4 任务调度
4. 实际项目中的应用
4.1 项目背景
4.2 项目需求
4.3 实现步骤
5. 总结 引言 ThingsBoard 是一个开源的物联网平台提供了设备管理、数据收集、处理和可视化等功能。规则链是 ThingsBoard 中的一个强大功能允许用户定义复杂的业务逻辑来处理设备上报的数据。在规则链中GCP Pub/Sub 节点用于将消息发布到 Google Cloud Pub/Sub 主题。本文将详细介绍 GCP Pub/Sub 节点的用法、含义以及在实际项目中的应用场景。 ThingsBoard从入门到实战课程深入透析底层原理快速搭建自己的IOT平台_哔哩哔哩_bilibiliThingsBoard从入门到实战课程深入透析底层原理快速搭建自己的IOT平台共计36条视频包括1、ThingsBoard项目介绍、2、ThingsBoard前端Vue版本代码编译、3、ThingsBoard本地后端源码编译等UP主更多精彩视频请关注UP账号。https://www.bilibili.com/video/BV1CH36egEDM/?spm_id_from333.999.0.0 1. GCP Pub/Sub 节点简介
GCP Pub/Sub 节点的主要作用是在规则链执行过程中将消息发布到 Google Cloud Pub/Sub 主题。Google Cloud Pub/Sub 是一种完全托管的消息传递服务支持发布/订阅模式可以实现不同系统和服务之间的解耦和异步通信。通过使用 GCP Pub/Sub 节点可以将设备上报的数据或处理结果发送到 Pub/Sub 主题再由其他服务或系统消费这些消息实现数据的进一步处理和分析。
2. 节点配置
项目 ID指定 Google Cloud 项目的 ID。主题名称指定要发布的 Pub/Sub 主题名称。凭据文件提供包含 Google Cloud 凭据的 JSON 文件路径用于身份验证。消息指定要发送的消息内容可以是静态文本或动态变量。
2.1 基本配置示例
{projectId: your-project-id,topicName: your-topic-name,credentialsFile: /path/to/credentials.json,message: This is a test message from ThingsBoard
}
3. 使用场景
GCP Pub/Sub 节点在多种场景下都非常有用特别是在需要将设备数据发送到 Google Cloud 服务进行进一步处理和分析的场景中。以下是一些具体的应用场景
3.1 数据传输
在需要将设备上报的数据发送到 Google Cloud Pub/Sub 时可以通过 GCP Pub/Sub 节点将数据发送到指定的主题。
{projectId: your-project-id,topicName: device-data-topic,credentialsFile: /path/to/credentials.json,message: Device ${msg.deviceId} reported data: ${msg.data}
}
3.2 数据分析
在需要对设备数据进行实时分析时可以通过 GCP Pub/Sub 节点将数据发送到 Google Cloud Pub/Sub再由 Google Cloud Dataflow 或其他服务进行处理和分析。
{projectId: your-project-id,topicName: data-analysis-topic,credentialsFile: /path/to/credentials.json,message: Device ${msg.deviceId} reported data: ${msg.data}
}
3.3 事件通知
在需要发送事件通知时可以通过 GCP Pub/Sub 节点将事件消息发送到 Pub/Sub 主题再由其他服务或系统消费这些消息进行通知。
{projectId: your-project-id,topicName: event-notification-topic,credentialsFile: /path/to/credentials.json,message: Event occurred for device ${msg.deviceId}: ${msg.eventType}
}
3.4 任务调度
在需要调度任务时可以通过 GCP Pub/Sub 节点将任务消息发送到 Pub/Sub 主题再由任务调度系统消费这些消息执行任务。
{projectId: your-project-id,topicName: task-scheduling-topic,credentialsFile: /path/to/credentials.json,message: Task scheduled for device ${msg.deviceId}: ${msg.taskDetails}
}
4. 实际项目中的应用
下面是一个实际项目中的例子展示如何在智能家居系统中使用 GCP Pub/Sub 节点。
4.1 项目背景
假设我们正在开发一个智能家居系统该系统需要支持用户通过手机应用控制家中的灯光、空调等设备并记录设备的状态和使用情况。此外还需要将设备数据发送到 Google Cloud Pub/Sub 进行进一步处理和分析。
4.2 项目需求
记录设备的状态例如当前温度、湿度等。记录设备的使用情况例如开关次数、能耗等。实现实时反馈确保用户能够及时了解操作结果。将设备数据发送到 Google Cloud Pub/Sub 进行进一步处理和分析。
4.3 实现步骤 部署设备 在家中安装智能灯光、空调等设备并连接到 ThingsBoard 平台。 创建规则链 添加 GCP Pub/Sub 节点用于将设备上报的数据发送到 Google Cloud Pub/Sub。添加其他处理节点如设备控制、状态查询和数据存储。 配置规则链 配置 GCP Pub/Sub 节点用于发送设备数据。
{projectId: your-project-id,topicName: device-data-topic,credentialsFile: /path/to/credentials.json,message: Device ${msg.deviceId} reported data: ${msg.data}
}
处理数据 根据业务逻辑动态地将设备数据发送到 Google Cloud Pub/Sub。
// 发送设备数据到 Google Cloud Pub/Sub
public void sendDeviceDataToPubSub(String projectId, String topicName, String deviceId, String data) {// 配置 GCP Pub/Sub 节点JsonNode config JsonNodeFactory.instance.objectNode().put(projectId, projectId).put(topicName, topicName).put(credentialsFile, /path/to/credentials.json).put(message, Device deviceId reported data: data);gcpPubSubNode.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. 总结 GCP Pub/Sub 节点在 ThingsBoard 规则链中是一个非常有用的工具可以帮助你将消息发布到 Google Cloud Pub/Sub 主题实现数据的进一步处理和分析。通过合理地使用 GCP Pub/Sub 节点可以在数据传输、数据分析、事件通知和任务调度等场景中确保系统的高效性和灵活性。 项目地址
Things Vuehttp://thingsvue.tpson.cn:7772/#/login?redirect/tb-home/index
账号adminthingsboard.org
密码admin123456 安装使用
获取项目代码
代码地址https://gitee.com/tpsonwell_admin/thingsvue
