当前位置： 首页 > news >正文

ThingsBoard的数据分析-自定义节点来订阅kafka stream的消息

news 2026/4/25 7:42:22

1、概述

在ThingsBoard官方文档中有说明：ThingsBoard 规则引擎支持对传入遥测数据的基本分析，例如阈值交叉。规则引擎背后的想法是提供基于设备属性或数据本身将数据从物联网设备路由到不同插件的功能。
然而，大多数现实生活中的用例也需要高级分析的支持：机器学习、预测分析等。

本教程将向您展示如何：

  • 使用内置规则引擎功能将遥测设备数据从 ThingsBoard 路由到 Kafka 主题（适用于 ThingsBoard CE 和 PE）。
  • 使用简单的 Kafka Streams 应用程序聚合来自多个设备的数据。
  • 使用 ThingsBoard PE Kafka 集成将分析结果推送回 ThingsBoard 进行持久化和可视化。

注意：上面第三点 "使用 ThingsBoard PE Kafka 集成将分析结果推送回 ThingsBoard 进行持久化和可视化" 目前在ThingsBoard CE版是不支持集成功能的，所以我们没办法拿到kafka stream 分析完之后的数据，所以就引出了这一章的重点：自定义规则节点来订阅kafka stream 的消息并且从规则链往后传输进行后续的逻辑处理。

2、流程架构图

如下如所示：这张图很形象的说明了ThingsBoard使用kafka stream 对设备数据进行分析的流程：

设备上传的数据通过规则节点 "kafka" 将数据推到kafka的的 IN TOPIC 中，然后使用kafka st

相关文章：

ThingsBoard的数据分析-自定义节点来订阅kafka stream的消息

1、概述 在ThingsBoard官方文档中有说明：ThingsBoard 规则引擎支持对传入遥测数据的基本分析，例如阈值交叉。规则引擎背后的想法是提供基于设备属性或数据本身将数据从物联网设备路由到不同插件的功能。 然而，大多数现实生活中的用例也需要高级分析的支持：机器学习、预测分…...

编程日记 2023/10/21 10:42:50

Python WSGI HTTP Server - Gunicorn

基本概念 Gunicorn，也称为“Green Unicorn”，是一个Python WSGI HTTP Server，用于运行Python Web应用程序。WSGI（Web Server Gateway Interface）是Python应用程序和Web服务器之间的一个接口，允许应用程序和…...

编程日记 2023/10/21 10:41:49

[论文笔记]GPT-2

引言 今天继续GPT系列论文， 这次是Language Models are Unsupervised Multitask Learners，即GPT-2，中文题目的意思是 语言模型是无监督多任务学习器。 自然语言任务，比如问答、机器翻译、阅读理解和摘要，是在任务相关数据集上利用监督学习的典型方法。作者展示了语言模型…...

编程日记 2023/10/21 10:40:47

第十三届蓝桥杯模拟赛第三期

A.填空题 问题描述 请问十六进制数 2021ABCD 对应的十进制是多少？ 参考答案 539077581 import java.math.*; public class Main {public static void main(String[] args) {String strnew BigInteger("2021ABCD",16).toString(10);System.out.printl…...

编程日记 2023/10/21 10:39:45

代碼隨想錄算法訓練營|第四十四天|01背包问题 二维、01背包问题 一维、416. 分割等和子集。刷题心得（c++）

目录 01背包問題 - DP二維數組 01 背包問題描述 暴力解 動態規劃 確認DP數組以及下標的含意 確定遞推公式 01背包问题 一维 一维DP 数組(滾動数組) 動態規劃五部曲 定義DP数組以及其下標含意 遞推公式 初始化 遍歷順序 讀題 416. 分割等和子集 自己看到题目的第…...

编程日记 2023/10/21 10:38:44

【算法训练-回溯算法 零】回溯算法解题框架

抽象地说，解决一个回溯问题，实际上就是遍历一棵决策树的过程，树的每个叶子节点存放着一个合法答案。你把整棵树遍历一遍，把叶子节点上的答案都收集起来，就能得到所有的合法答案。站在回溯树的一个节点上，你…...

编程日记 2023/10/21 10:37:42

GAN.py

原代码地址：github.com/zqhang/MTGFLOW 目录 def ConvEncoder() def ConvDecoder() class CNNAE(torch.nn.Module): class R_Net(torch.nn.Module): class D_Net(torch.nn.Module): def R_Loss（） def D_Loss（&#xff09…...

编程日记 2023/10/21 10:36:41

C语言动态内存管理

1.为什么要动态内存分配？ int val 20; int a[10]{0};上面我们声明并定义了一个大小为4字节的整型变量，一个容量为10*4字节的整型数组。 开辟方式:我们在栈上开辟。 开辟空间的方式有两个特点： 1. 空间开辟 大小是固定 的。 2. 数组在申明…...

编程日记 2023/10/21 10:35:39

小红书商品详情API接口（商品详情页面数据接口)

小红书商品详情API接口（商品详情页面数据接口 小红书商品详情API接口（商品详情页面数据接口）代码对接如下： 1.公共参数 名称类型必须描述keystring是get请求方式拼接在url中,点击获取api_namestring是 api接口名称cachestrin…...

编程日记 2023/10/21 10:34:38

nginx配置文件的内容解释和简化方案

文章目录 配置文件内容理解配置文件精简nginx.confapp1.conf 配置文件内容理解 events {worker_connections 1024; }http {include mime.types;default_type application/octet-stream;sendfile on;keepalive_timeout 65;client_max_body_size 50m;client…...

编程日记 2023/10/21 10:33:37

Java设计模式之访问者模式（Visitor Pattern）

访问者模式（Visitor Pattern）是一种行为型设计模式，它允许在不修改现有对象结构的情况下定义新的操作。该模式将操作封装在一个访问者对象中，使得可以在不改变被访问对象的类的前提下，通过访问者对象对被访问对象进行新…...

编程日记 2023/10/21 10:32:36

others-AppLovin广告接入

title: others-AppLovin广告接入 categories: Others tags: [广告, AppLovin] date: 2023-10-20 10:07:01 comments: false mathjax: true toc: true others-AppLovin广告接入 前篇 官方 - https://www.applovin.com/ Android sdk - https://github.com/AppLovin/AppLovin-MAX…...

编程日记 2023/10/21 10:31:35

ESP32集成开发环境Espressif-IDE安装 – Windows

陈拓 2023/10/15-2023/10/16 1. 概述 Espressif IDE是一个基于Eclipse CDT的集成开发环境（IDE），用于使用ESP-IDF框架开发物联网应用程序。这是一个专门为ESP-IDF构建的独立定制IDE。Espressif IDE附带了IDF Eclipse插件、重要的Eclipse CDT插…...

编程日记 2023/10/21 10:30:34

python之if else语句介绍

python之if else语句介绍 在Python中，if和else是两种重要的控制流语句，它们用于根据特定的条件来执行不同的代码块。以下是它们的用法和详细介绍： 1）if语句 if语句用于在满足某种条件时执行特定的代码块。它的基本语法如下&#…...

编程日记 2023/10/21 10:29:32

Java版ORM最初雏形

经过一个晚上的加班，终于把ORM初步结构工程搭好了。工程依赖有点难用，编辑器提示比VS差很多。 首先LIS.Core创建一个最初的容器雏形，先能反射得到对象给ORM获得数据库驱动 然后ORM创建数据库驱动差异接口，不同数据库实现接口后配…...

编程日记 2023/10/21 10:28:32

黎曼几何与切空间之间的投影

公式： 从黎曼空间投影到切空间，其中P为黎曼均值，也是切空间的参考中心点，Pi是要投影到切空间的点。 从切空间投影回来，其中Si为切空间中的向量。 function Tcov CovToTan(cov,Mcov)Cm12 Mcov^(-1/2);X_new logm(Cm…...

编程日记 2023/10/21 10:27:31

【Tomcat】为Tomcat服务配置本地Apr库以提升性能

关于 apr 和 apr-util 对 Tomcat 服务的性能提升的说明： 要测APR给tomcat带来的好处最好的方法是在慢速网络上（模拟Internet），将Tomcat线程数开到300以上的水平，然后模拟一大堆并发请求。如果不配APR，基本…...

编程日记 2023/10/21 10:26:30

普通人在当前大环境下——少看宏观，多看具体

前言 宏观叙事，简而言之，就是从宏观把握历史社会的发展，寻找其中永恒的共性。我们大概听过此类的话：贸易战导致本地经济下滑、气候变化是因为过去几十年的工业发展、大环境不行导致不赚钱。此类叙事方式，身边人聊的甚欢，在媒体、社交圈、日常社群交流中，随处可见。以前…...

编程日记 2023/10/21 10:25:28

用echarts在vue2中实现3d饼图

先看效果，再看文章： 一、安装插件 3d的图不仅用到echarts，还用到了echarts-gl，因此都需要安装一下哦~ npm install echarts npm install echarts-gl2.0.9 //可以指定版本，也可不指定二、在main.js中引入 import * …...

编程日记 2023/10/21 10:24:27

低代码助力软件开发

低代码开发工具正在日益变得强大，它正不断弥合着前后端开发之间的差距。对于后端来说，基于低代码平台开发应用时，完全不用担心前端的打包、部署等问题，也不用学习各种框架（Vue、React、Angular等等）&#x…...

编程日记 2023/10/21 10:22:24

C++ STL string模拟实现全解析

C STL string 模拟实现（下）1. 迭代器实现class MyString {// ... 成员变量声明 public:using iterator char*;using const_iterator const char*;iterator begin() noexcept { return _str; }iterator end() noexcept { return _str _size; }const_it…...

编程新知 2026/4/25 4:51:37

Pointer-Generator模型架构深度解析：编码器、解码器与指针网络的完美融合

Pointer-Generator模型架构深度解析：编码器、解码器与指针网络的完美融合 【免费下载链接】pointer-generator Code for the ACL 2017 paper "Get To The Point: Summarization with Pointer-Generator Networks" 项目地址: https://gitcode.com/gh_mir…...

编程新知 2026/4/25 3:50:35

未来3年，这3个AI赛道已经定了

我最近一直在想一件事。Anthropic上个月的年化收入超过了OpenAI。很多人看到这条新闻，觉得不过是个财报数字。但我觉得这是一个信号——一个新产业正式成型的信号。这个产业叫AI编程。先说为什么是Anthropic，不是OpenAIOpenAI体量更大，名气更…...

编程新知 2026/4/25 3:03:58

企业级WLAN部署与安全优化实战指南

1. 企业级WLAN部署核心架构解析现代企业无线网络已从简单的"有线替代"演变为支撑移动办公的关键基础设施。根据IDC最新调研数据，采用系统化部署方案的企业WLAN网络，员工生产力平均提升27%，会议室利用率提高40%。要实现这些效益&…...

编程新知 2026/4/25 2:49:37

Stacking集成学习：提升机器学习模型性能的实战技巧

1. 集成学习与Stacking方法概述在机器学习实践中，单个模型往往存在性能瓶颈。Stacking（堆叠泛化）作为一种高级集成技术，通过分层组合多个基学习器的预测结果，能够显著提升模型表现。与简单的投票或平均法不同&#xff…...

编程新知 2026/4/25 2:49:37

从IBUF到OBUFDS：手把手拆解Spartan-6 SelectIO原语，搞定你的自定义接口

从IBUF到OBUFDS：Spartan-6 SelectIO原语实战指南 在FPGA开发中，SelectIO资源的灵活运用往往是实现高性能自定义接口的关键。对于Xilinx Spartan-6系列器件而言，其SelectIO架构提供了丰富的原语（Primitive）支持&#xf…...

编程新知 2026/4/25 2:34:21

远程开发环境突然断连？资深SRE披露VSCode Remote Extension 1.92+版本3个未公开的session保活机制

更多请点击： https://intelliparadigm.com 第一章：远程开发环境断连现象的典型特征与影响面分析 远程开发环境（如 VS Code Remote-SSH、GitHub Codespaces、JetBrains Gateway）在企业级协作中日益普及，但其稳定性高度…...

编程新知 2026/4/25 0:39:13

Vim配置拯救计划：手把手教你备份、迁移和版本化管理你的 .vimrc 与插件

Vim配置工程化：打造可移植、可版本化的高效开发环境 你是否经历过这样的场景：换了一台新电脑，却发现精心调教的Vim配置无法复现；团队协作时，每个成员都要从零开始配置开发环境；或是系统崩溃后，那…...

编程新知 2026/4/24 22:55:22

AI SoC全芯片DFT实战

01景芯DFT实战课景芯团队DFT专家老师授课，一对一辅导，主打文档服务器实战，通过3个系列课程依次完成HD6850各个关键子系统的DFT设计实战后，再完成下图全芯片TOP DFT实战，让您快速超越同龄人！我们不卖视频&am…...

编程新知 2026/4/24 22:39:17

3分钟免费追踪Elsevier期刊审稿进度：科研工作者的效率革命

3分钟免费追踪Elsevier期刊审稿进度：科研工作者的效率革命 【免费下载链接】Elsevier-Tracker 项目地址: https://gitcode.com/gh_mirrors/el/Elsevier-Tracker 还在为Elsevier期刊投稿后的漫长等待而焦虑不安吗？每天手动刷新页面、频繁检查邮件…...

编程新知 2026/4/24 22:30:06