数据管理

多流数据汇总:按实验运行对齐,缺失超时补零后写 HDF5。

概述

quatm/servers/datamgr.py 提供数据管理(DataSummary):汇总多个输入通道的数 据流,整理成每个 run 的完整字典。收到数据先累积在 incompleteData,当所有订阅通 道的数据都到达时整条记录移入 completeData;若 run 结束超时仍有数据未到,缺失部 分以零补齐。

关键方法

方法说明
initDataq(重新)订阅属性里配置的通道与实验开始/结束事件
recvData / processIncomingData接收数据并归并到最近的 run 记录
savetoFile把收集的 run 字典写入 HDF5 结构化数据集
loadFromFile从 HDF5 读回一组已存的 run 字典
clear清空已收集的全部数据
run_forever阻塞式循环持续接收数据

用法

from quatm.servers.datamgr import DataSummary

summary = DataSummary(name="sum")
summary.initDataq()     # 订阅属性中配置的通道
summary.run_forever()   # 持续收数;savetoFile 把 run 字典写入 .h5