智慧档案馆信创适配环境监控平台与恒温恒湿设备对接方案关键词信创适配、智慧档案馆、环境监控平台、恒温恒湿设备、国产操作系统、国产数据库、Modbus TCP、BACnet/IP、南向对接、北向集成、协议栈替换、等保合规标签#物联网 #Modbus #TCP/IP #POE供电 #InfluxDB #以太网温湿度传感器 #网口温湿度变送器 #机房监控 #边缘计算 #信创 #国产数据库 #等保合规一、场景界定信创适配到底改什么信创不是把 x86 换成 ARM、把 CentOS 换成统信就完事。档案馆环境监控系统的适配本质是在国产软硬件栈上重建一条从感知到平台到处置的可用链路并保证交付后运维动作不变形。先分清适配边界避免把精力花错地方基础设施层服务器飞腾/鲲鹏/海光/兆芯、操作系统统信 UOS、麒麟 Kylin V10、虚拟化/容器运行时kubelet、containerd 或 podman、消息中间件。数据层时序库替换InfluxDB 原生包在部分国产架构下缺 arm64/rpm或许可协议不合规、关系库达梦、人大金仓 KingbaseES、OceanBase、缓存Redis 国产替代或原栈移植。采集层边缘网关国产化、Python 解释器/PyModbus 依赖、Cgo 依赖库、交叉编译产物。对接层恒温恒湿机组南向协议Modbus TCP / BACnet/IP / 厂家私有 SDK北向与 BA、消防、门禁、视频平台集成。合规层等保三级备案、商用密码应用、日志审计、漏洞加固基线。核心目标原系统功能等价迁移 南向设备对接不回退 运维工具链可用。二、总体架构与适配分层┌──────────────────────────────────────────────────────────────────┐ │ 北向集成层信创平台内 │ │ Web控制台 / Grafana替代国产BI或自研前端 / 告警通知 / 工单 │ │ REST API WebSocket MQ │ └──────────────────────┬───────────────────────────────────────────┘ │ 内部数据总线Kafka/NATS/Redis Stream信创验证 ┌──────────────────────▼───────────────────────────────────────────┐ │ 平台服务层国产OS国产库 │ │ 采集网关管理 · 设备模型 · 点表映射 · 联动规则引擎 · 审计日志 │ └──────────────────────┬───────────────────────────────────────────┘ │ 北向协议代理 / EdgeAgent ┌──────────────────────▼───────────────────────────────────────────┐ │ 边缘层信创边缘节点或工控机 │ │ 协议转换 · 缓存 · 本地自治 · 断网续传 │ └──────────────────────┬───────────────────────────────────────────┘ │ Modbus TCP / BACnet/IP / MQTT ┌──────────────────────▼───────────────────────────────────────────┐ │ 设备层 │ │ 网口温湿度变送器 · DDC/PLC · 恒温恒湿机组控制器 · 水阀/风阀执行器 │ └──────────────────────────────────────────────────────────────────┘复制适配时坚持三条原则协议面不动软件栈动南向机组通信协议、寄存器表、BACnet 对象表保持不变适配的是运行这些协议的进程和依赖。接口契约不动实现替换设备模型、点表映射表、北向 API schema 保持稳定后端可换国产库、国产中间件。降级路径保留国产栈出问题时边缘侧仍能本地闭环平台侧可回退到旁路监控。三、平台侧信创迁移3.1 操作系统与运行时OS 验证矩阵统信 UOS Server 20、麒麟 V10 SP3确认内核版本、systemd、SELinux/kysec 策略、软件源。容器化部署优先容器化降低环境耦合。确认 containerd/podman 在目标架构可用镜像多架构构建buildx 或交叉编译。非容器化部署systemd unit 托管chroot/venv 隔离别直接污染系统 Python。架构差异x86_64 → aarch64鲲鹏、飞腾 FT-2000/S2500或 x86_64 国产CPU海光、兆芯。PyModbus、asyncio 无碍C 扩展orjson、cryptography、InfluxDB client 底层需确认 wheel 或源码编译。3.2 Python 依赖与构建锁定依赖清单离线 wheelhouse在目标 OS架构下 pip download / pip install --target别现场编译。关键依赖核查pymodbus 3.x纯 Python asyncio跨平台 OK注意异常码、事务ID处理。bacpypes3BACnet/IP纯 Pythonaarch64 无问题性能敏感时评估多设备轮询开销。influxdb-clientHTTP 写无 C 依赖若替换国产时序库改写入适配层。redis / pika / confluent-kafkaKafka 客户端纯 Python 可选 kafka-pythonlibrdkafka 绑定需编译。构建产物进制品库CI 中加架构标签部署时按 nodeSelector/亲和性下发。3.3 数据层替换原栈 InfluxDBTSDB信创场景常见两种路径保留 InfluxDB OSS确认 v2.x 在 aarch64 有官方二进制或容器镜像无则自行构建评估维护成本。许可证与内网分发合规。替换为国产/兼容栈时序数据TDengine国产arm64 支持好、IoTDB清华开源Java 生态信创友好。关系/配置/审计达梦 DM8、KingbaseES V8ORM 或原生驱动适配。迁移策略双写过渡期校验后切读历史数据回灌脚本化。适配层建议抽象存储接口避免业务代码散落多库方言# store_backend.py - 存储适配层参考 from abc import ABC, abstractmethod class MetricSink(ABC): abstractmethod async def write_point(self, measurement, tags, fields, ts): ... class InfluxSink(MetricSink): def __init__(self, client): self.c client async def write_point(self, m, tags, fields, ts): from influxdb_client import Point p Point(m).time(ts) for k,v in tags.items(): p p.tag(k,v) for k,v in fields.items(): p p.field(k,v) self.c.write_api().write(recordp) class TDEngineSink(MetricSink): def __init__(self, conn): self.conn conn # taosrest 或 taospy async def write_point(self, m, tags, fields, ts): cols ,.join(list(tags.keys())list(fields.keys())) vals ,.join([f{v} if isinstance(v,str) else str(v) for v in list(tags.values())list(fields.values())]) sql fINSERT INTO {m} ({cols}) VALUES ({vals}) await self.conn.execute(sql)复制北向查询接口同样抽象前端/报表不改 SQL 细节。3.4 北向集成REST/WebSocket 网关FastAPI/Sanago 国产栈运行无碍注意 uvicorn/gunicorn 多 worker 下共享状态。与既有 BA/IBMS 对接OPC-UA、BACnet/WS、MQTT Sparkplug B或厂家 API 代理。国密改造TLS 替换国密套件TLCP或前置国密网关证书签发接入政务 CA/内网 PKI。等保操作审计、登录双因子、最小化端口、日志集中采集。四、南向设备对接适配4.1 恒温恒湿机组接口清点交付前拿到的对接物料信创环境下不变通信卡型号、固件版本、协议类型、端口502/TCP47808/UDP。Modbus 寄存器表0-based offset、数据类型、缩放、线圈/保持寄存器区分。BACnet 对象表device-id、object-list、present-value 可读写性、priority-array。写操作语义设定值下发、启停、模式切换、故障复位是否需 DDC 中间层。4.2 边缘网关适配边缘 Agent 容器化下发配置外置 ConfigMap/文件挂载。多协议采集分片Modbus TCP 连接池BACnet Who-Is/Read-Property 缓存。协议栈在国产 OS 上的网络行为验证BACnet/IP 广播发现跨 VLAN 时 BBMDiptables/nftables 规则、SELinux/kysec 放行。本地自治平台失联时DDC/边缘侧维持闭环恢复后增量续传。续传缓冲别无限增长环形缓冲时标去重。4.3 点表映射与版本化统一设备模型device → subsystemhvac → points[]绑定固件版本、点表版本。映射配置 YAML/JSON热加载变更留审计。写回路径平台下发目标带/设定值 → 边缘代理校验限幅 → DDC 执行 → 回读确认。多厂商异构抽象成标准点setpoint_temp、setpoint_hum、run_state、fault_word、ret_temp、ret_hum、valve_pos下游适配插件化。4.4 参考实现信创边缘采集代理 edge_agent.py - 信创边缘侧采集与北向上行精简参考 - 读配置连南向设备归一化后写本地缓冲北向MQTT - 接收北向下发写回设备失败退避状态回报 import asyncio, json, logging, signal from typing import Dict, Any from pymodbus.client import AsyncModbusTcpClient logging.basicConfig(levellogging.INFO) class EdgeAgent: def __init__(self, cfg: Dict[str, Any]): self.cfg cfg self.clients: Dict[str, AsyncModbusTcpClient] {} self.local_buf [] # 断网续传缓冲 self.uplink_ok False self._stop False async def modbus_read(self, dev): host dev[host]; unit dev[unit] c self.clients.get(host) if c is None or not c.connected: c AsyncModbusTcpClient(host, portdev.get(port,502)) await c.connect() self.clients[host] c rr await c.read_holding_registers(0, 4, slaveunit) if rr.isError(): return None regs rr.registers # 示例ret_temp, ret_hum, setpoint_temp, setpoint_hum return { ret_temp: regs[0]/10.0, ret_hum: regs[1]/10.0, setpoint_temp: regs[2]/10.0, setpoint_hum: regs[3]/10.0, } async def modbus_write_setpoint(self, dev, sp_t, sp_h): c self.clients.get(dev[host]) if c is None or not c.connected: return False # 写保持寄存器 2,30-based offset缩放回原值 await c.write_registers(2, [int(sp_t*10), int(sp_h*10)], slavedev[unit]) # 回读确认 rr await c.read_holding_registers(2, 2, slavedev[unit]) if rr.isError(): return False got_t, got_h rr.registers[0]/10.0, rr.registers[1]/10.0 return abs(got_t-sp_t) 0.2 and abs(got_h-sp_h) 0.5 async def poll_loop(self): while not self._stop: for dev in self.cfg[devices]: try: state await self.modbus_read(dev) if state: msg {device: dev[id], ts: asyncio.get_event_loop().time(), state: state} # 北向上行MQTT示意实际接信创消息总线 await self.publish(msg) self.local_buf.append(msg) except Exception as e: logging.warning(poll %s: %s, dev[id], e) await asyncio.sleep(self.cfg.get(poll, 5.0)) async def publish(self, msg): # 占位NATS/Kafka/MQTT over TLS/国密网关 self.uplink_ok True async def control_handler(self, cmd): dev next(d for d in self.cfg[devices] if d[id]cmd[device]) ok await self.modbus_write_setpoint(dev, cmd[sp_t], cmd[sp_h]) return {ack: ok, device: cmd[device]} def stop(self): self._stop True async def main(): cfg json.load(open(/etc/edge_agent/config.json)) agent EdgeAgent(cfg) loop asyncio.get_event_loop() for s in (signal.SIGTERM, signal.SIGINT): loop.add_signal_handler(s, agent.stop) await agent.poll_loop() if __name__ __main__: asyncio.run(main())复制落地时注意生产环境把配置加载、指标暴露Prometheus exporter、健康探针、优雅退出、日志轮转补上国密/TLS 在消息总线侧终结别在采集进程内硬绑。五、联调与验证5.1 迁移前后功能对齐数据面采样频率、时标、单位、质量位与原系统一致。控制面下发设定值、启停、模式切换DDC 跟随行为一致。告警面规则触发、通知路由、抑制窗、升级通知等价。审计面操作日志、联动 trace、配置变更留痕。5.2 协议联调# Modbus TCP 抓包 tcpdump -i any -nn host 10.20.1.11 and port 502 -w /tmp/mb.pcap # BACnet/IP tcpdump -i any -nn port 47808 -w /tmp/bac.pcap # 国产OS上确认监听与连通 ss -tlnp | grep 502 nc -zv 10.20.1.11 502复制Wireshark 过滤modbus、bacnet验证事务ID匹配、异常响应码、广播分发。BACnet 跨网段配 BBMD 或静态绑定确认 I-Am/Read-Property/Write-Property。5.3 故障注入平台服务宕机边缘侧维持本地闭环恢复后增量同步。国产库主备切换写入不丢、读取最终一致。网络分区边缘缓冲水位监控避免磁盘撑满。固件升级后点表变化映射版本不匹配时降级到只读并告警不停写错寄存器。国密网关证书过期回退通道告警别阻断控制面。六、合规与安全等保三级边界防护、访问控制、审计、恶意代码防范信创环境别默认放行收敛端口。商用密码存储加密、传输国密套件、密钥生命周期管理。漏洞管理国产 OS 补丁源、依赖扫描容器镜像入仓前扫描。供应链国产组件 BOM、许可证合规InfluxDB 商用场景确认 OSS 许可边界避免违规分发。审计留痕配置变更、控制下发、告警处置全链路可追溯日志留存≥6个月。七、交付与运维交付物适配清单BOM架构OS版本、部署手册、回滚手册、点表/对象表版本库、容器镜像仓库、离线依赖包。回滚保留原 x86 环境并行运行一段时间灰度切流异常时切回数据以原系统为准或双向同步。运维工具链国产 OS 下日志查看、服务启停、配置热加载、缓冲清理、备件更换 SOP。培训现场人员会重启服务、会查日志、会切旁路、会触发恢复 SOP别依赖原厂远程。八、常见坑国产 OS 上 pip 装不上 pymodbus3/bacpypes3源里是旧版——建离线 wheelhouseCI 中预编译。InfluxDB 镜像无 arm64现场编译耗时且不稳定——早做存储抽象TDengine/IoTDB 备选。SELinux/kysec 拦截采集进程绑端口、写缓冲——策略模块或放通域别直接关安全模块。国密 TLS 与原有 MQTT 客户端不兼容——终结在前置网关应用侧明文/内网 TLS。DDC 写回权限未确认平台以为下发成功——联调时回读校验控制面测试覆盖。多架构镜像标签混乱边缘节点拉错——部署时校验 archkubelet/nodeSelector 或手动锁定。等保测评时暴露审计日志缺失——上线前接集中日志别事后补。双写过渡期数据不一致切读后曲线断层——校验脚本回灌切流前冻结配置。九、小结信创适配不是协议重做是运行栈迁移前提下的对接保全南向机组接口契约不变边缘代理与平台服务在国产 OS国产库上重建重点投入在依赖构建、存储抽象、北向集成、合规加固和回滚预案。交付完成度看三件事——采样等价、控制可回读、故障下边缘自治。