买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网获悉哈尔滨航天恒星数据系统科技有限公司申请的专利一种基于分布式架构平台的实时流计算和服务调度方法及系统获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN119718582B 。

龙图腾网通过国家知识产权局官网在2025-06-27发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202411869281.4，技术领域涉及：G06F9/48；该发明授权一种基于分布式架构平台的实时流计算和服务调度方法及系统是由赵辉;马刚;陆林;苏杨;王书琪设计研发完成，并于2024-12-18向国家知识产权局提交的专利申请。

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

本发明授权一种基于分布式架构平台的实时流计算和服务调度方法及系统在权利要求书中公布了：1.一种基于分布式架构平台的实时流计算和服务调度方法，其特征在于，包括以下步骤： S1.搭建基于分布式架构平台的实时流计算和服务调度系统； S2.在实时流计算和服务调度系统的自定义任务调度中心中，集成ApacheAirflow组件，定义有向无环图工作流，并制定调度规则与策略； S3.在实时流计算和服务调度系统的自定义流式计算处理中心中，集成StreamEngineParser组件的流计算引擎，进行流式计算，将计算结果存储到DolphinDB数据库，完成实时流计算和服务调度； 所述S2中，具体包括以下步骤： S21.自定义任务调度中心中，通过java调用ApacheAirflow组件构建有向无环图工作流，其中每个节点代表一个任务，边代表任务之间的依赖关系； S22.添加有向无环图工作流的任务节点，任务节点包含数据源获取、数据预处理、特征提取、实时分析，定义任务的执行顺序和依赖关系； S23.设置有向无环图工作流的属性，确保有向无环图工作流按照预定的周期和时间点开始执行； S24.根据构建的有向无环图工作流和任务的依赖关系，使用自定义任务调度中心中的调度器调度任务执行，引入综合优先级计算，得到调度综合优先级； S25.根据调度综合优先级，设计异常处理与容错机制，得到调度规则与策略，实现任务的自动重试机制，当任务执行失败时，根据预设的重试次数和延迟时间间隔自动重新调度任务； 所述S24中，综合优先级计算的过程具体如下： S241.使用归一化的方法，将任务的紧急程度表示为当前时间与截止时间之差的相对值，计算得到任务紧急程度优先级Pu,i； 任务紧急程度优先级Pu,i表示为： 其中，Di表示当前任务i的截止时间，T表示当前时间，Dj表示任一任务的截止时间； S242.通过将任务资源需求与任务集中最大资源需求相比较，计算得到资源需求优先级Pr,i； 资源需求优先级Pr,i表示为： 其中，Ri表示当前任务i所需的资源量，Rj表示任一任务所需的资源量； S243.使用任务的入度和出度作为任务的依赖关系优先级的度量，计算得到任务的依赖关系优先级Pd,i； 任务的依赖关系优先级Pd,i表示为： 其中，Dei表示当前任务i对应的依赖关系因子，Dej表示任一任务对应的依赖关系因子； S244.计算得到综合优先级Pt,i； Pt,i＝a·Pu,i+b·Pr,i+c·Pd,i 其中，a表示第一权重系数，其用于调整紧急程度在优先级计算中的比重，b表示第一权重系数，其用于调整资源需求在优先级计算中的比重，c表示第一权重系数，其用于调整任务的依赖关系在优先级计算中的比重，且a+b+c＝1； 所述S3中，具体包括以下步骤： S31.为DolphinDB数据库配置可选流计算引擎，包括响应式状态引擎、横截面引擎和时间序列引擎，并通过配置JSON文件方式，将StreamEngineParser组件集成到DolphinDB数据库环境中； S32.在DolphinDB数据库中定义包括输入表、输出表和自定义算法的流计算参数； S33.在DolphinDB数据库中编写一个脚本，订阅输入表，调用自定义的算法，并将结果发布到输出表； S34.通过StreamEngineParser组件构建流水线，将用户自定义算法转化为能被底层硬件直接理解和执行高效的计算指令，计算指令包括数据读取指令、数据处理指令和数据输出指令，并对计算指令进行优化，执行优化后的计算指令，得到计算结果； S35.将计算结果实时存储于DolphinDB数据库中，或根据业务需求将结果发送至指定的输出目的地； 所述S32中，先定义输入表，输入表包括指标名称、指标值和时间戳，再定义输出表，输出表包括计算出的预测值和对应的时间戳，最后定义用户根据业务需求设置算法逻辑的自定义算法。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人哈尔滨航天恒星数据系统科技有限公司，其通讯地址为：150028 黑龙江省哈尔滨市高新技术产业开发区科技创新城创新路1616号5号楼；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。