Python 轻量版本 | 边缘代理 | 协议采集 | 源码交付 | 支持联动 DG-IoT 主平台
iotStudio (边缘) DG-IoT (中枢) iotStudio (应用)
Python · 轻量代理 Erlang · 高性能 Vue3 · 低代码
┌────────────────┐ MQTT/HTTP ┌──────────────────┐ REST ┌──────────────┐
│ parse_lite │ ─────────→ │ EMQX 汇聚 │ ←───── │ 12页管理后台 │
│ SQLite / PG │ ←───────── │ Parse Server │ │ 7插件架构 │
│ TDengine 时序 │ │ TDengine · 集群 │ │ 动态菜单 │
│ 协议·采集·解析 │ │ 规则·告警·本体 │ │ 2D组态·拓扑 │
└────────────────┘ └──────────────────┘ └──────────────┘
<1000 设备/节点 >10万 设备汇聚 用户交互层
# 1. 安装依赖
pip install -r requirements.txt
# 2. 启动平台 (SQLite 零安装, 无需 PG/TDengine)
python run.py
# → http://localhost:8000 管理后台
# → http://localhost:8000/docs Swagger API
# 3. (可选) 初始化种子数据
python scripts/init_dgiot.py| 协议 | 文件 | 说明 |
|---|---|---|
| Modbus TCP/RTU | protocols/modbus_tcp.py |
多从站轮询，寄存器扫描 |
| A11 | protocols/a11.py |
油气生产物联网 5a5a 帧 |
| OPC UA | pymodbus / asyncua | 订阅 + 轮询 |
| OPC DA | DCOM 识别 | RSLinx 协议可识 |
| IEC 104 | protocols/ |
电力远动规约 |
| 方案 | 用途 | 安装 |
|---|---|---|
| SQLite | 默认 (零安装) | 内置 |
| PostgreSQL | 生产环境多租户 | 可选 |
| TDengine 3.x | 时序数据 | 可选, 无则降级 SQLite |
| 功能 | 说明 |
|---|---|
| CRUD | POST/GET/PUT/DELETE /classes/{ClassName} |
| 查询 | $ne $lt $gt $in $nin $exists $regex $or $and |
| 用户 | signup / login / logout / session |
| 角色 | _Role 创建, 层级, 用户关联 |
| ACL | 对象级 {user/role}:{read/write} |
| CLP | 类级 find/get/create/update/delete |
| 批量 | POST /batch (max 50) |
| Hooks | beforeSave / afterSave / beforeDelete / afterDelete |
| 功能 | 落点 |
|---|---|
| 租户 CRUD | web/tenant_api.py（薄壳，读写全经 parse_lite） |
| 角色层级 | _Role.parent_id (对齐 DG-IoT _Role) |
| 用户-租户关联 | _Join_users_Role |
| 请求隔离 | X-Tenant-ID header + JWT |
Site (工业站点) → Gateway (IO网关) → Device (RTU/站点) → Point (测点)
↓
MQTT: dgiot/{site}/{gateway}/{device}/{point}/data
ontology.py — 四层模型 + sync_to_parse() 自动创建 Parse Device 对象。
📊 监控 仪表盘 (KPI+趋势+告警等级+日志)
🔌 设备 设备管理 · 产品管理 (TSL分区+导入导出)
🗺️ 组态 组态视图 (设备拓扑+流程组态 tabs 联调)
📡 数据 数据分析 · 告警管理 · 流计算引擎 · 预测性维护
🔧 网络 报文解析 · 通道管理 · 边缘代理
🛠️ 工具 MQTT调试 · 模拟器管理
⚙️ 系统 系统概览 · 运维管理 · 用户管理
// manifest.js — 部署时按需启用
hub: false, // 不需要边缘中枢联调 → Vite tree-shake 自动裁掉
network: true, // 需要报文解析通道插件按 manifest.js 按需启用，支持自定义厂商协议接入。
iotStudio/
├── run.py # 启动入口
├── config.yaml # TDengine/MQTT/Parse 配置
├── src/
│ ├── main.py # FastAPI 应用
│ ├── parse_lite.py # Parse Server Python 兼容层
│ ├── ontology.py # 4层本体引擎
│ ├── auth.py # JWT + 多租户中间件
│ ├── protocols/ # Modbus/A11/OPC/IEC104
│ ├── storage/tdengine.py # TDengine + SQLite 降级
│ ├── models/ # dgiot_schema + device ORM
│ ├── services/ # collector · phm · safety_rules
│ └── web/ # tenant_api
├── frontend-vue/
│ └── src/
│ ├── plugins/ # 7插件 (manifest tree-shaking)
│ ├── views/ # 12页 Vue3 SFC
│ └── components/ # ChannelCard · NotifyBell · RunningCards
├── scripts/ # 初始化 · 种子数据
├── simulators/ # 协议模拟器
└── tests/ # 集成测试
config.yaml:
# 存储 (无则降级 SQLite)
tdengine:
host: "tdengine.example.com" # 远端 TDengine (可选，示例)
port: 6041
# Parse-lite 嵌入式
parse:
db_path: "./data/parse.db" # SQLite 单机版
# 多租户
storage_mode: "sqlite" # sqlite | postgres| 端点 | 说明 |
|---|---|
GET /api/health |
健康检查 |
GET/POST /api/devices |
设备管理 (DG-IoT Device) |
GET/POST /api/tenants |
租户/岗位管理（读写 Parse _Role，与数据面同一个源；对齐 DG-IoT _Role） |
POST /api/roleuser |
用户-角色分配 |
GET /api/alarms |
告警列表 |
GET /api/telemetry/{device_id}/{point_id} |
时序查询 |
GET /api/stats |
采集统计 |
WS /ws |
WebSocket 实时推送 |
iotStudio 采集数据通过 MQTT 推送至 DG-IoT 主平台：
iotStudio ──MQTT──→ EMQX (:1883) ──→ Parse Server ──→ TDengine
边缘代理 中枢汇聚 存储引擎 时序引擎
数据格式对齐 DG-IoT 物模型标准，实现边缘采集 → 中心汇聚的全链路。
- dgaiot — 中枢：EMQX fork + OWL 本体引擎（Erlang，本仓库的 hub 侧）
- dgiot — 完整 Erlang IoT 平台（稳定版中枢）
- GitHub 组织: https://github.com/dgiot · Issues: https://github.com/dgiot/iotStudio/issues
scripts/deploy_hub.sh 在 openEuler/Kylin 上源码构建并部署 DG-IoT 中枢（参考 dgaiot 单机部署思路，只装必要）：
- 不依赖 Docker，不改系统源，不装全家桶（无 ollama/milvus/dify/parse-server）
- 复用已有 TDengine/PostgreSQL，端口冲突预检（1883/8083/8084/18083）
- 全量走 gitee 镜像（github 依赖自动重写），幂等可重跑，systemd/nohup 双模式
sudo bash scripts/deploy_hub.sh # 默认 TAG=v4.9.3, 安装到 /data/dgiot
# TAG=v4.9.2 SRC=/opt/dgiot-4.2 sudo -E bash scripts/deploy_hub.sh # 自定义
python scripts/hub_smoke.py # 边缘→中枢 MQTT 回环验证本仓合并自 plugins-base（IOT 底座通用插件包），按能力归位、内容不丢失，详见 BASE_PLUGINS.md（English: BASE_PLUGINS_EN.md）。
This repo merged the shared IOT base plugin package (
plugins-base) with capability-based placement — nothing lost. See BASE_PLUGINS.md (中文) / BASE_PLUGINS_EN.md (English).
- 布局模板：
frontend-vue/src/components/ShellDark/（深色布局，可选）+CloseLoop/（闭环组件）+assets/base-icons.js - 轻量契约视图：
/iot/devices|products|channels（/api/iot/*，views/iot/） - 本体图谱：
/ontology-graph→public/ontology_graph.html（ECharts Force 图，本地 vendor 资源，离网可用；与ontology.htmlDLAS 树形互补） - 部署脚本：
scripts/ontology_server.py（本体图谱服务，回环 48765）、scripts/dsh-mobile-check.cjs（移动端验收，凭据走环境变量）——与init_db/seed_*/audit_ontology同目录 - url 型外链：菜单项
meta.external→ 新窗口打开（Sidebar 支持）
DGIOT LLC — Dallas, Texas, United States
- GitHub 组织: https://github.com/dgiot · Issues: https://github.com/dgiot/iotStudio/issues
- Docker Hub: https://hub.docker.com/u/dgiot
- 安全披露: 见 SECURITY.md
- 邮箱: LLC 信箱启用后公布（当前请通过 GitHub Issues / Security Advisories 联系）
- 分支: 活跃分支为
github-clean；仓内另一条master线与之无共同祖先（不是分叉， 是同一批代码被清洗过两次），已停止维护