(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211118807.6 (22)申请日 2022.09.15 (71)申请人 中国空气动力研究与发展中心高速 空气动力研究所 地址 621000 四川省绵阳市二环路南段6号 (72)发明人 王博文　黄叙辉　唐亮　高鹏　 桑博　秦建华　徐涛　蒋婧妍　 (74)专利代理 机构 绵阳远卓弘睿知识产权代理 事务所(普通 合伙) 51371 专利代理师 张忠庆 (51)Int.Cl. G06F 16/22(2019.01) G06F 16/2455(2019.01) G06F 16/2458(2019.01) G06F 16/25(2019.01)G06F 16/27(2019.01) G06F 16/28(2019.01) G06F 16/18(2019.01) (54)发明名称 一种风洞实时数据高效采集存 储系统 (57)摘要 本发明公开了一种风洞实时数据高效采集 存储系统， 涉及数据处理领域， 包括： 分布式采集 层， 其包括多个 分别接入多种风洞数据源的节点 服务器； 多采多存层， 其包括多个中心服务器； 采 存中间件， 其服务端分别部署在 多个中心服务器 上； 所述采存中间件的客户端分别部署在多个节 点服务器上； 分布式存储层， 其包括与多个中心 服务器进行连接的数据库群； 本发 明支持风洞多 类型多协议方式的数据分布式采集和分布式存 储， 实现系统对 大批量数据的高效处理和数据的 高效并行存储， 最终实现风洞实时数据从采集、 传输、 存储、 处理、 应用的全数据链路贯通， 为风 洞试验管 理系统与风洞现场信息系统的融合， 风 洞全链路贯 通提供数据支撑 。 权利要求书2页 说明书6页 附图3页 CN 115203213 A 2022.10.18 CN 115203213 A 1.一种风洞实时数据高效采集存 储系统， 其特 征在于， 包括： 分布式采集层， 其包括多个分别接入多种风洞数据源的节点 服务器； 多采多存层， 其包括多个中心服 务器； 采存中间件， 其服务端分别部署在多个中心服务器上； 所述采存中间件的客户端分别 部署在多个节点 服务器上； 分布式存 储层， 其包括与多个中心服 务器进行 连接的数据库群。 2.如权利要求1所述的一种风洞实时数据高效采集存储系统， 其特征在于， 多种所述风 洞数据源为三种， 分别为第一数据源、 第二数据源、 第三数据源； 所述第一数据源为控制系 统数据， 其通过PLC/PC ‑Base映射方式导入节点服务器； 所述第二数据源为测量系统数据， 其通过NI变量引擎/MQTT传输方式导入节 点服务器； 所述第三数据源为健康管 理系统数据， 其通过OPC/DA传输方式导入节点 服务器。 3.如权利要求2所述的一种风洞实时数据高效采集存储系统， 其特征在于， 多个所述节 点服务器为五个， 分别是两个第一节点服务器， 两个第二节点服务器， 一个第三节点服务 器； 多个所述中心 服务器为二个， 分别是中心主服务器和中心从服务器； 二个所述中心 服务 器分别连接五个节点服务器， 从而构成数据双采； 第一数据源分别连接两个第一节点服务 器； 第二数据源分别连接两个第二节 点服务器； 第三数据源连接其第三节点服务器； 多个所 述节点服务器之间以专用连接作为通讯链路实现互连， 且共同连接有一个时间同步服务 器。 4.如权利要求1所述的一种风洞实时数据高效采集存储系统， 其特征在于， 所述采存中 间件基于C#框架， 以多线程数据处理程序进行开发， 且驱动程序以DLL形式发布， 以实现程 序的模块 化。 5.如权利要求1所述的一种风洞实时数据高效采集存储系统， 其特征在于， 所述采存中 间件包括数据接口和接口组件； 所述数据接口和接口组件集成配置有PC ‑base、 Wonder ware 数据库、 NI共 享变量、 MQTT服务、 Modbus  TCP、 OPC DA/UA、 WebAPI、 Socket 工业数据驱动协议 的其中一种或多种。 6.如权利要求1所述的一种风洞实时数据高效采集存储系统， 其特征在于， 所述采存中 间件包括点配置组件； 所述点配置组件将创建与多个风洞数据源进行连接的采集点， 并通 过内置的逻辑分组结构实现数据采集和层次化管理。 7.如权利要求1所述的一种风洞实时数据高效采集存储系统， 其特征在于， 所述采存中 间件包括数据缓存组件； 所述数据缓存组件包括一个用于保存写入失败数据的InfluxDB缓 存数据库和一个相配套的服 务程序； 所述服务程序的具体实施流程被配置为： 在采存中间件向数据库群写入数据失败后， 会产生两种信息， 其中一种信息为日志， 将会直接保存在节点服务器本地， 并形成日志文 件； 另外一种信息为写入失败 数据， 将会直接 保存在InfluxDB缓存 数据库中； 通过定时读取 未处理的日志文件， 发现有写入失败数据时， 尝试将这些数据重新写入数据库群中， 如果写 入成功则删除日志文件或将日志文件状态变为已处理， 如果写入失败则不进行操作， 等待 下一次处 理。 8.如权利要求1所述的一种风洞实时数据高效采集存储系统， 其特征在于， 所述数据库 群均采用服务器加磁盘阵列的方式进 行部署； 所述数据库群包括一个与多个中心服务器对权　利　要　求　书 1/2 页 2 CN 115203213 A 2接的主从时序数据库； 所述主从时序数据库包括一个InfluxDB主数据库和一个InfluxDB从 数据库； 所述采存中间件的导出数据同时导入到InfluxDB主数据库和InfluxDB从数据库 中； 所述InfluxDB主数据库和InfluxDB从数据库之间相互连接， 以保持数据同步， 从而构成 数据双写。 9.如权利要求8所述的一种风洞实时数据高效采集存储系统， 其特征在于， 所述数据库 群还包括一个SQL  Server数据库； 所述SQL  Server数据库分别与InfluxDB主数据库和 InfluxDB从数据库连接 。 10.如权利要求1所述的一种风洞实时数据高效采集存储系统， 其特征在于， 所述采存 中间件上配置有实时数据发布接口； 所述实时数据发布接口可被配置为MQTT、 WebAPI其中 一种。权　利　要　求　书 2/2 页 3 CN 115203213 A 3