数据管理
多流数据汇总:按实验运行对齐,缺失超时补零后写 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