物联网后端数据可视化消息队列【免费下载链接】thingsboardAll-in-one IoT Platform - Device management, data collection, processing and visualization.项目地址https://gitcode.com/GitHub_Trending/th/thingsboard点击查看免费下载导读本文聚焦 ThingsBoard 规则引擎中的**字段模板化Fields Templatization**机制一种用预定义占位符在运行时动态提取消息数据、替换规则节点配置中静态值的方案。它在 REST API 调用、邮件通知、MQTT 转发、告警创建等节点的配置字段中广泛使用让配置从写死变为实时。读完本文你将掌握$[...]与${...}两类模板的完整语法、解析行为、边界条件并能在任意规则节点中写出可复用的动态配置。什么是字段模板化模板化Templatization是用预定义模板在文本中动态插入或替换值的过程。模板作为变量的占位符可稍后用真实数据填充。在规则引擎语境下模板用于在运行时从传入的消息中提取数据。这一点在规则节点配置中特别有价值通过模板化配置字段中的静态值可被替换为来自传入消息的实时值从而支持基于动态输入的条件运算与灵活、自动化的数据处理。例如当某条遥测异常时把读数连同设备信息动态拼接到外部 API 的 URL 中——这些信息只有在消息到达时才知道无法在配置阶段写死。在 ThingsBoard 中消息由两部分组成见 TbMsg.java 中data与metaData两个字段消息数据Message DataJSON 格式的载荷通常是设备上报的遥测如{temperature: 26.5}消息元数据Message Metadata键值对集合TbMsgMetaData.java 内部为MapString, String存放deviceName、deviceType、ts等系统在消息处理过程中附加上下文。模板化正是围绕这两部分展开的$[...]读取消息数据${...}读取消息元数据。模板语法模板以美元符号$开头后接括号包裹的键名语法取值来源说明$[messageKey]消息数据Message Data提取传入消息中messageKey的值${metadataKey}消息元数据Message Metadata提取元数据中metadataKey的值其中messageKey与metadataKey代表消息或其元数据中可能存在的任意键名。两种语法可混用于同一条模板字符串中也可与普通文本自由组合。与源码实现对应该语法在 TbNodeUtils.java 中定义private static final Pattern DATA_PATTERN Pattern.compile((\\$\\[)(.*?)(])); private static final String ALL_DATA_TEMPLATE $[*]; private static final String ALL_METADATA_TEMPLATE ${*};DATA_PATTERN正则匹配$[key]形式formatDataVarTemplate与formatMetadataVarTemplate两个工具方法分别构造$[key]与${key}源码第 115-121 行。此外还有两个特殊模板$[*]代表整个消息数据 JSON${*}代表整个元数据 JSON 对象消息为空时替换为{}可用于需要整体透传原始 JSON 的场景。实战示例构建动态 REST API URL下面是一个完整的端到端示例。假设某设备上报的消息数据如下{ temperature: 26.5, humidity: 75.2, soilMoisture: 28.9, windSpeed: 26.2, location: riverside }消息元数据如下{ deviceType: weather_sensor, deviceName: weather1, ts: 1685379440000 }现在业务上检测到风速异常偏高需要把这条遥测推送到外部 REST API且每条读数必须关联到具体设备和地点——这些信息只在消息到达的实时时刻才可用正适合模板化example-base-url.com/report-reading?location$[location]deviceName${deviceName}该模板在运行时被解析为example-base-url.com/report-reading?locationriversidedeviceNameweather1模板化的价值正在于此配置时未知、运行时才确定的值无需人工介入即可动态注入。REST API 调用节点中的真实落地在 ThingsBoard 的 REST API Call 节点TbRestApiCallNode.java及其底层 HTTP 客户端 TbHttpClient.java 中模板化被用于各个可动态化的字段REST 端点 URLString endpointUrl TbNodeUtils.processPattern(config.getRestEndpointUrlPattern(), task.msg());第 333 行查询参数名与值processPattern(param.key(), ...)与processPattern(param.value(), ...)第 339-340 行请求体模板processPattern(config.getRequestBodyTemplate(), msg, escapeJson)第三个参数escapeJson表示是否对结果做 JSON 转义第 473 行请求头键值对 header 的 key 与 value 均做模板解析第 565 行这印证了模板可嵌入 URL、请求头、请求体等任意文本字段的设计并且escapeJson参数对应源码中的escapeJsonValue方法基于 Jackson 的JsonStringEncoder用于把模板结果安全地转义后嵌入 JSON 请求体中。模板解析的完整行为规则1. 可与普通文本组合模板可与普通文本自由拼接。例如Fuel tanks are filled to$[fuelLevel]%——当fuelLevel为87时输出 Fuel tanks are filled to87%。2. 嵌套键使用点号访问可通过点号.访问 JSON 对象中的嵌套键$[object.key]。该行为在 TbNodeUtils.java 中实现解析到$[key]后以.分割键名逐层深入JsonNode直到最终节点为**值节点isValueNode**才进行替换。3. 缺失键或对象/数组值模板原样返回若指定键缺失或键对应的值是对象object或数组array则模板字符串将原样返回、不做替换。这是保证配置健壮性的关键设计例如$[array]、$[object]不会被替换成 JSON 片段避免破坏下游字段格式。行为对照表以下面这条消息为例{ number: 123.45, string: text, boolean: true, array: [1, 2, 3], object: { property: propertyValue }, null: null }各模板与实际提取值的对照如下TemplateExtracted value$[number]123.45$[string]text$[boolean]true$[array]$[array]$[object]$[object]$[object.property]propertyValue$[null]null$[doesNotExist]$[doesNotExist]要点总结原始类型数字、字符串、布尔、null可提取对象与数组原样保留不存在的键原样保留。模板在各类规则节点中的应用模板化并非某单个节点的特性而是贯穿规则引擎的通用机制。在 rule-engine-components 模块中调用TbNodeUtils.processPattern / processPatterns的节点超过 30 个覆盖主要节点族动作类Action创建告警 TbCreateAlarmNode.java、清除告警 TbClearAlarmNode.java、创建/删除关系 TbCreateRelationNode.java、变更属主 TbChangeOwnerNode.java外部系统集成Kafka TbKafkaNode.java、MQTT TbMqttNode.java、RabbitMQ TbRabbitMqNode.java、AWS Lambda/SNS/SQS、GCP Pub/Sub、Slack TbSlackNode.java、Twilio SMS/语音邮件to email 节点 TbMsgToEmailNode.java 中from、to、cc、bcc、subject、body全部支持模板第 86-94 行并在模板之外额外支持%d{pattern}日期格式化语法转换与元数据变更发起者 TbChangeOriginatorNode.java、获取遥测/属性、延迟 TbMsgDelayNode.java、数学运算 TbMathNode.javaAI 与 RESTAI 节点 TbAiNode.java、REST API Call 节点及其底层 TbHttpClient.java。此外UI 帮助文档目录中还配套有面向具体节点的模板化说明例如 change_originator_node_fields_templatization.md 与 common_node_fields_templatization.md可在 ThingsBoard 界面中各节点的帮助面板中直接查看。底层解析流程源码级TbNodeUtils.processPattern(String pattern, TbMsg tbMsg)是模板化的核心入口TbNodeUtils.java其完整流程为解析元数据模板先以MapString, String形式的元数据对模板做替换——遍历元数据所有键值对把${key}替换为对应值${*}特殊模板被替换为整个元数据 JSON空元数据时为{}处理$[*]特殊模板将整个消息数据 JSON 字符串替换进去逐条解析数据模板若消息数据是 JSON 对象用DATA_PATTERN正则匹配所有$[key]按.分割键名逐层访问JsonNode仅当最终是值节点时替换为文本escapeJsonValues为真时先做 JSON 转义对象/数组/缺失键不替换返回最终文本任何异常如数据不是合法 JSON都会包装为RuntimeException(Failed to process pattern!)抛出。processPatterns(ListString patterns, TbMsg tbMsg)则是对模式列表的批处理封装逐个调用上述流程后返回结果列表常用于需要对一组字符串同时做模板化的节点配置。使用注意事项模板即配置的一部分在规则节点 UI 的对应字段中直接输入含模板的文本即可无需任何额外开关区分数据与元数据$[...]只能取消息数据中的键${...}只能取元数据中的键二者不可混用若写错来源例如用$[deviceName]取元数据中的设备名将因键缺失而原样保留模板对象与数组不会被展开若需要整个对象或数组请改用$[*]/${*}特殊模板或先把目标键映射为元数据再引用结果转义把模板结果嵌入 JSON 请求体时ThingsBoard 会通过escapeJson参数对值做转义避免特殊字符破坏 JSON 结构失败即报错模板解析失败会抛出运行时异常从而将消息导向节点的 Failure 分支方便用错误处理链路定位问题。小结字段模板化是 ThingsBoard 规则引擎实现配置动态化的核心机制$[messageKey]提取消息数据、${metadataKey}提取元数据支持嵌套键、普通文本混排、整包透传$[*]/${*}并以缺失键/对象/数组原样保留的宽容策略保证配置健壮性。它被 30 余种规则节点复用是编写可复用、自适应规则链的基本功。赞分享物联网后端数据可视化消息队列【免费下载链接】thingsboardAll-in-one IoT Platform - Device management, data collection, processing and visualization.项目地址https://gitcode.com/GitHub_Trending/th/thingsboard点击查看免费下载相关推荐ThingsBoard 规则引擎 customer attributes 节点字段模板化Fields Templatization实战指南ThingsBoard 规则引擎 customer attributes 节点字段模板化Fields Templatization实战指南 customer物联网后端数据可视化消息队列ThingsBoard 规则引擎字段模板化实战originator attributes 节点动态属性查询ThingsBoard 规则引擎字段模板化实战originator attributes 节点动态属性查询 导读 本文围绕 ThingsBoard 规则引擎中物联网后端数据可视化消息队列Bottle SimpleTemplatestpl模板引擎完全指南语法、内置函数与源码原理Bottle SimpleTemplatestpl模板引擎完全指南语法、内置函数与源码原理 Bottle 框架自带一套名为 SimpleTemplate后端Web框架上一篇golang-migrate/migrate与Terraform集成基础设施即代码下一篇3分钟搭建Websocket健康检查从崩溃检测到自动恢复的实战指南创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考