公开(公告)号：CN119718582A

公开(公告)日：2025-03-28

申请号：CN202411869281.4

申请日：2024-12-18

Applicant: 哈尔滨航天恒星数据系统科技有限公司

Inventor： 赵辉 ,  马刚 ,  陆林 ,  苏杨 ,  王书琪

IPC: G06F9/48 ,  G06F9/50

Abstract: 本发明公开了一种基于分布式架构平台的实时流计算和服务调度方法及系统，属于实时流计算和调度策略技术领域。解决了现有技术中传统的实时流计算和服务调度方法资源利用率低且计算效率低的问题；本发明搭建基于分布式架构平台的实时流计算和服务调度系统；在实时流计算和服务调度系统的自定义任务调度中心中，集成工作流调度和管理平台，定义有向无环图工作流，并制定调度规则与策略；在自定义流式计算处理中心中，集成用于实时流数据处理的解析器的流计算引擎，进行流式计算，将计算结果存储到DolphinDB数据库，完成实时流计算和服务调度。本发明有效提升了数据处理效率和服务响应速度，可以应用于大规模数据流处理。

公开(公告)号：CN116401562A

公开(公告)日：2023-07-07

申请号：CN202211603319.4

申请日：2022-12-13

Applicant: 哈尔滨航天恒星数据系统科技有限公司

Inventor： 于雷 ,  李宗鑫 ,  董丽娜 ,  姜宇 ,  李积祥 ,  马刚

IPC: G06F18/23

Abstract: 本发明涉及海量移动定位数据处理领域，更具体的说是一种基于时空格式的移动终端数据聚类方法，该方法包括以下步骤：S1：构造数据源集合；S2：提取数据特征点，获取数据特征点集合；S3：计算数据特征点集合之间的空间距离；S4：计算数据特征点集合之间的时间间隔；S5：标准化的空间距离和时间间隔权重，计算数据特征点集合间的时空相似性；S6：采用聚类方法完成数据特征点集合的聚类；获取的特征点能够准确的反映移动终端数据的轨迹结构，提升了聚类移动轨迹数据划分的精度。

公开(公告)号：CN119739800A

公开(公告)日：2025-04-01

申请号：CN202411809595.5

申请日：2024-12-10

Applicant: 哈尔滨航天恒星数据系统科技有限公司

Inventor： 赵辉 ,  王兆祥 ,  王伟 ,  马刚 ,  王星博

IPC: G06F16/29 ,  G06Q50/26

Abstract: 本发明公开了基于污水管网模型的入流入渗分析方法、电子设备及计算机可读存储介质，属于污水管入流入渗监测技术领域。解决了现有技术中传统的污水管网监测方法难以实现对入流入渗位置精准定位的问题；本发明基于二维水动力模型结合水质、流量监测点数据，构建污水管网模型；基于发布的GeoServer地图服务，使得水质、流量监测点数据显示在电子地图上；将实时的水质、流量监测数据在GeoServer地图服务上展示；通过计算得到的污水管线入流入渗值，确定入流入渗隐患点；将分析得到的入流入渗隐患点传输至GeoServer地图服务，进行入流入渗分析结果展示。本发明实现了确定入流入渗隐患点，可以应用于污水管网入流入渗分析。

公开(公告)号：CN114091217A

公开(公告)日：2022-02-25

申请号：CN202111361262.7

申请日：2021-11-17

Applicant: 哈尔滨航天恒星数据系统科技有限公司

Inventor： 王建勋 ,  李积祥 ,  董丽娜 ,  赵希奇 ,  李思嘉 ,  马刚 ,  李宗鑫

IPC: G06F30/18 ,  G06F30/28 ,  G06F113/14

Abstract: 本发明涉及计算机应用领域，更具体的说是一种基于水力模型虚拟节点的供水漏损位置定位方法，步骤一：供水管网进行简化和水力模型参数化设置，形成供水管网水力模型；步骤二：自动添加虚拟节点；步骤三：计算供水管网漏损位置；模拟各个节点不同漏量的漏损情况；模拟节点漏损数据与供水管网实际监测数据比对计算供水管网漏损位置；通过对供水管线水力模型自动添加虚拟节点，利用虚拟水力模型模拟管网发生漏损时的管网监测点的压力、流量数据，构建模拟值与实测值的目标函数，找到令目标函数值达到最小的节点位置则为漏损位置，同时给出可疑漏损量，在计算能力允许的情况下，可对供水管网漏损位置精细化模拟。

公开(公告)号：CN112597205A

公开(公告)日：2021-04-02

申请号：CN202011608430.3

申请日：2020-12-30

Applicant: 哈尔滨航天恒星数据系统科技有限公司

Inventor： 姜宇 ,  周含笑 ,  刘源 ,  于雷 ,  王兆祥 ,  董丽娜 ,  李墨野 ,  王建勋 ,  赵辉 ,  邵文杰 ,  马刚

IPC: G06F16/2455 ,  G06F16/27 ,  G06F16/25 ,  G06F16/28 ,  G06F9/54

Abstract: 本发明涉及一种基于流及消息调度的实时数据计算及存储方法，包括如下步骤：步骤一、数据流缓冲，建立大数据高并发场景下的数据缓冲通道，采用kafka系统为数据消费者提供消峰后的稳定数据源；步骤二、实时数据分析，通过准实时流计算引擎，根据实际需求完成海量实时数据的在线运算分析；步骤三、实时数据存储，源数据根据时间点存入分布式时序数据库，实现大数据的实时性时序存储及历史数据检索。本发明提供的方法，可应用于海量数据的实时数据分析存储系统中，提升其快速数据处理能力、实时运算响应速度、海量数据存储能力以及满足数据订阅需求。