dgaiot

工业物联网聚合引擎

Erlang/OTP · 百万级设备 · 设备影子 · 本体 · gen_statem

---

DLAS 架构

  ┌──────────────────────────────────────────────────────────────────┐
  │                    EDGE: iotStudio (Python+Vue)                   │
  │  DeviceAccess(9) → UnifiedPipeline → StreamEngine(15) → Alert(6) │
  └──────────────────────────┬───────────────────────────────────────┘
                             │ MQTT / HTTP
  ┌──────────────────────────▼───────────────────────────────────────┐
  │  SECURITY    auth · role · ACL/CLP · Hooks · JWT                 │
  ├──────────────────────────────────────────────────────────────────┤
  │  ACTION      Shadow(gen_statem) · Bridge · MQTT · Rule Engine   │
  │              init → auth → online → {normal, alarm, offline}    │
  ├──────────────────────────────────────────────────────────────────┤
  │  LOGIC       Ontology Engine · Model Registry · 3 ETS Tables     │
  │              load_model → compile → spawn → evaluate → reason    │
  ├──────────────────────────────────────────────────────────────────┤
  │  DATA        Parse(23 Classes) · PG(:7432)                       │
  │              TDengine(_{ProductId}, devaddr NCHAR(50))           │
  │              EMQX(:1883) · Mnesia/ETS                             │
  └──────────────────────────────────────────────────────────────────┘

完整 HTML 架构图

FDE 流水线

Model → Ontology → Device Access → TimeSeries → Rules → Dashboard
  1        2           3              4           5          6

数据流

Modbus 40300 → MQTT(dgiot/{site}/{gw}/{dev}/{pt}/data) → Shadow PID
  → evaluate(Rules) → state transition → Parse + TDengine INSERT

本体：DLAS

层级	功能	关键技术
数据	23 个 Parse 类、TDengine、Mnesia/ETS	JSONB、SuperTable/SubTable、_{ProductId}
逻辑	load_model、spawn_instance、注册表、规则、推理器	3 张 ETS 表、gen_statem 编译
动作	设备影子 1:1 设备进程、桥接、MQTT	gen_statem OTP、ont_push_point
安全	认证、角色树、ACL（对象）、CLP（类）、钩子	JWT、Parse ACL

完整本体文档 · 存储架构 · 站点仿真

模块

应用	层级	职责
dgiot	数据	核心 — EMQX、规则引擎、告警
dgiot_ontology	逻辑	模型注册表、推理器、实例生成器
dgiot_parse	数据	Parse Server REST 客户端
dgiot_task	动作	设备影子 gen_statem 工作进程
dgiot_device	逻辑	设备管理 + 物模型
dgiot_bridge	动作	协议桥接框架
dgiot_dlink	动作	数据链路层
dgiot_api	安全	REST API + 认证网关
dgiot_http	—	HTTP 服务层
dgiot_tdengine	数据	TDengine 时序连接器

快速开始

git clone git@gitee.com:dgaiot/dgaiot.git
cd dgaiot
export PATH=/usr/local/erlang_24.3/bin:$PATH
make

相关项目

• iotStudio — 边缘代理与应用（Python + Vue）
• dgiot — 完整的 Erlang 物联网平台

许可协议

Apache 2.0