如何通过 websocket 从 Thingsboard 检索所有客户设备的遥测数据
How to retrieve telemetry for all customer devices from Thingsboard via websocket
我想通过 API 通过 websocket 从 thingsboard CE 获取与单个客户相关的所有设备的最新遥测数据。这样我就可以在收到测量值时实时更新 jquery 数据表。
after 通过 GUI 手动添加 customer->device
的关系最新遥测数据现在正在流向 Thingsboard 中的 CUSTOMER entityType。
但是;返回的数据不包含任何我可以用来将 ws 响应与生成测量值的设备相匹配的设备属性信息。
{"subscriptionId":10,"errorCode":0,"errorMsg":null,"data":{"battery_voltage":[[1559065098932,"2.8623046875"]],"pressure":[[1559065098932,"0.05001525953412056"]],"relative_humidity":[[1559065098932,"53.7109375"]],"temperature":[[1559065098932,"83.78323364257812"]]},"latestValues":{"battery_voltage":1559065098932,"temperature":1559065098932,"pressure":1559065098932,"relative_humidity":1559065098932}}
Thingsboard 中的端点:/api/ws/plugins/telemetry
此代码有效且 returns 最新遥测更新,但未指定返回结果中的设备。
$( document ).ready(function() {
...
webSocket.onopen = function () {
var object = {
tsSubCmds: [{
entityType: "CUSTOMER",
entityId: "00000000-0000-0000-0000-0000...",
scope: "LATEST_TELEMETRY",
cmdId: 10
}
],
historyCmds: [],
attrSubCmds: []
};
var data = JSON.stringify(object);
webSocket.send(data);
console.log("Message is sent: " + data);
console.log("socket open: ");
};
如何使用设备属性丰富遥测时间序列数据?
我找到的解决方案是更新 GUI 中的 rule-chain,以便复制传入的设备遥测数据的副本并保存到相关的客户实体。
一步一步:
以租户管理员身份登录 thingsboard
点击Root Rule Chain
找到 Post telemetry
分支上的 Save timeseries
节点
将新的 filter...script
节点拖到 canvas
将新脚本节点连接到 Post Telemetry
分支上 Save timeseries
节点的输出
编辑过滤器脚本名称:-> Should Duplicate
编辑过滤器脚本函数 -> return true;
拖一个新的Transformation...change originator
节点到canvas
将新的转换节点连接到过滤器节点的输出
编辑转换节点名称:Reassign to Customer
编辑原创者来源:Customer
将一个新的 Action...save timeseries
节点拖到 canvas
将新的 Action 节点连接到 Transformation 节点的输出
编辑动作节点名称:Save Related Telemetry
您的根规则链现在应该类似于:
我想通过 API 通过 websocket 从 thingsboard CE 获取与单个客户相关的所有设备的最新遥测数据。这样我就可以在收到测量值时实时更新 jquery 数据表。
after 通过 GUI 手动添加 customer->device
的关系最新遥测数据现在正在流向 Thingsboard 中的 CUSTOMER entityType。
但是;返回的数据不包含任何我可以用来将 ws 响应与生成测量值的设备相匹配的设备属性信息。
{"subscriptionId":10,"errorCode":0,"errorMsg":null,"data":{"battery_voltage":[[1559065098932,"2.8623046875"]],"pressure":[[1559065098932,"0.05001525953412056"]],"relative_humidity":[[1559065098932,"53.7109375"]],"temperature":[[1559065098932,"83.78323364257812"]]},"latestValues":{"battery_voltage":1559065098932,"temperature":1559065098932,"pressure":1559065098932,"relative_humidity":1559065098932}}
Thingsboard 中的端点:/api/ws/plugins/telemetry
此代码有效且 returns 最新遥测更新,但未指定返回结果中的设备。
$( document ).ready(function() {
...
webSocket.onopen = function () {
var object = {
tsSubCmds: [{
entityType: "CUSTOMER",
entityId: "00000000-0000-0000-0000-0000...",
scope: "LATEST_TELEMETRY",
cmdId: 10
}
],
historyCmds: [],
attrSubCmds: []
};
var data = JSON.stringify(object);
webSocket.send(data);
console.log("Message is sent: " + data);
console.log("socket open: ");
};
如何使用设备属性丰富遥测时间序列数据?
我找到的解决方案是更新 GUI 中的 rule-chain,以便复制传入的设备遥测数据的副本并保存到相关的客户实体。
一步一步:
以租户管理员身份登录 thingsboard
点击
Root Rule Chain
找到
Post telemetry
分支上的Save timeseries
节点将新的
filter...script
节点拖到 canvas将新脚本节点连接到
Post Telemetry
分支上Save timeseries
节点的输出编辑过滤器脚本名称:->
Should Duplicate
编辑过滤器脚本函数 ->
return true;
拖一个新的
Transformation...change originator
节点到canvas将新的转换节点连接到过滤器节点的输出
编辑转换节点名称:
Reassign to Customer
编辑原创者来源:
Customer
将一个新的
Action...save timeseries
节点拖到 canvas将新的 Action 节点连接到 Transformation 节点的输出
编辑动作节点名称:
Save Related Telemetry
您的根规则链现在应该类似于: