iot-processer
所属分类：物联网
开发工具：JavaScript
文件大小：22KB
下载次数：0
上传日期：2019-02-13 06:46:43
上 传 者：
sh-1993
说明： 基于 nodejs + kafka + redis 实现的 编程式物联网数据解码单元
(Programmed IoT data decoding unit based on nodejs+kafka+redis)
文件列表:
.vscode (0, 2019-02-13)
.vscode\launch.json (369, 2019-02-13)
index.js (92, 2019-02-13)
index_consumer.js (181, 2019-02-13)
index_producer.js (246, 2019-02-13)
index_redis.js (185, 2019-02-13)
package.json (280, 2019-02-13)
src (0, 2019-02-13)
src\config (0, 2019-02-13)
src\config\config.js (246, 2019-02-13)
src\obj (0, 2019-02-13)
src\obj\DeviceData.js (196, 2019-02-13)
src\server (0, 2019-02-13)
src\server\mainServer.js (2567, 2019-02-13)
src\service (0, 2019-02-13)
src\service\HexDataProcessorService.js (1924, 2019-02-13)
src\service\JsonDataProcessorService.js (1366, 2019-02-13)
src\service\StringDataProcessorService.js (1394, 2019-02-13)
src\utils (0, 2019-02-13)
src\utils\ConsumerUtils.js (561, 2019-02-13)
src\utils\ProducerUtils.js (1156, 2019-02-13)
src\utils\RedisUtils.js (404, 2019-02-13)
yarn.lock (35296, 2019-02-13)
# iot-processer
基于 nodejs + kafka + redis 实现的 编程式物联网数据解码单元
## 特点
- 编程式解码规则定义
基于 JavaScript 脚本语言特性(代码注入),支持自定义编程式解码规则
- 分布式支持
## 说明
### 前置
数据接入端接入设备数据后,通过特征标示分类推送到 kafka 消息队列,等待 iot-processer 模块消费解码数据
平台总体架构设计
### 环境依赖
- node
- kafka
- redis
### 配置
```js
const config = {
name: 'json', // 解码器名称,用于标记解码所需加载的规则标记 (json string Hex ..)
topic: 'JSON_OPIC', // 监听的topic,获取支持解码的数据
redis: {
// redis配置信息
host: '192.168.0.201',
port: 6379,
db: 14
},
kafka: {
// kafka配置信息
kafkaHost: '192.168.10.120:6667,192.168.10.121:6667,192.168.10.122:6667'
}
}
```
### 流程
### 代码
加载依赖 `yarn install` or `npm install --save`
启动 `node index.js`
### 解码器规则实例
```
key-data-change-rule-5601808030001129
{
"str": {
"processorFn": "const arr = data.split(':'); return[{attr: arr[0],val:arr[1]}];"
},
"hex": {
"framework": { // hex 偏移量规则 本例基于 modbus 协议制定
"address": 2,
"command": 2,
"length": 2,
"data": "*",
"crc": 4
},
"data": "data", // 数据属性名
"dataChangeFn": [ // 数据转换格式,位置参数
"data = data + 'ms'; return{attr:'SSLL',val:data};",
"data = data + 'ms'; return{attr:'LJLL',val:data};"
],
"checkTag": "crc",
"checkFn": {
},
// 解码规则 (基于 modbus 协议)
"processorFn": "const count = data.length / 8;const dataItemList = [];let offset = 0;for (let i = 1; i <= count; i++){let subData = data.slice(offset, offset + 8);const h = subData.slice(0, 4);const l = subData.slice(4, 8);const data_bit = parseInt(l + h, 16).toString(2);const data_E = parseInt(data_bit.slice(0, 8), 2);const data_M = data_bit.slice(8, ***);let data_M_10 = 0.0;for (var j = 0; j < data_M.length; j++){data_M_10 = data_M_10 + data_M[j]* Math.pow(2, -1 * (j + 1));}const readData = Math.pow(2, data_E - 127) * (1 + data_M_10);dataItemList.push(readData);offset += 8;}return dataItemList;"
},
"json": {
"processorFn": "const jsonStr = JSON.parse(data);const datas = jsonStr.data;return [{attr:'YL',val:datas[0].ch1}];"
}
}
```
```
key-attr-topic-rule-5601808030001129
{
"Signal": [
"realtime-status-topic",
"pgsql-topic"
],
"SSLL": [
"pgsql-topic"
],
"LJLL": [
"pgsql-topic"
],
"YL": [
"pgsql-topic"
]
}
```
近期下载者：
相关文件：
收藏者：