一种分布式作业调度和执行方法插件化的方法及系统

    公开(公告)号:CN114579326B

    公开(公告)日:2024-09-27

    申请号:CN202011382758.8

    申请日:2020-12-01

    Abstract: 本发明提供了一种分布式作业调度和执行系统插件化的方法及系统,方法包括:包括:插件配置管理步骤、插件任务配置管理步骤、插件版本管理步骤、插件缓存管理步骤、任务触发执行管理步骤和插件任务执行步骤。本发明已经在工业互联网平台xIn3Plat中得到实现,实现了定制化业务作业的执行,本发明已经在多个数据治理项目中得以使用,在保障了分布式作业调度和执行系统稳定性可靠性的前提下,有效解决了分布式作业调度和执行系统轻松满足各种复杂且频繁变更的业务需求的场景,在今后任何应用xIn3Plat的项目中,都可以应用本发明。

    基于领域模型工业互联网异构资源的统一管理方法及系统

    公开(公告)号:CN116126837A

    公开(公告)日:2023-05-16

    申请号:CN202111349947.X

    申请日:2021-11-15

    Inventor: 胡于龙 黄明 周明

    Abstract: 本发明提供了一种基于领域模型工业互联网异构资源的统一管理方法及系统,包括:模型建立模块:按照层级关系建立工业互联网异构资源的领域模型;数据处理模块:工业互联网异构资源中软件资源的数据采集、数据编辑、数据查看和数据删除;物联网设备模块:工业互联网异构资源中物联网设备资源的数据采集和数据查看;资源管理模块:工业互联网异构资源统一管理和统一权限管理。本发明解决了在现有的工业互联网系统架构中,海量异构资源很难实现资源共享,在各部门和各软件系统中的流动与共享困难重重的问题;解决工业互联网系统架构中海量的异构资源的统一管理问题,使得业务人员沟通起来更顺畅。

    面向工业4.0的时空大数据分布式存储检索方法及系统

    公开(公告)号:CN112749160A

    公开(公告)日:2021-05-04

    申请号:CN201911063015.1

    申请日:2019-10-31

    Abstract: 本发明提供了一种面向工业4.0的时空大数据分布式存储检索方法,其特征在于,包括:数据接收步骤:接收窄带物联网实时产生的时空大数据;时空大数据图层存储步骤:将时空大数据图层存储到ElasticSearch中;时空大数据图层检索步骤:对时空大数据图层进行检索;时空大数据存储步骤:将时空大数据存储到ElasticSearch中;时空大数据检索步骤:在ElasticSearch中检索时空大数据;时空过程大数据存储步骤:将时空过程大数据存储到ElasticSearch中;时空过程大数据检索步骤:在ElasticSearch中检索时空过程大数据。本发明充分利用ElasticSearch实时搜索的高性能,极大的提高了时空大数据存储及检索性能。

    工业数据资产标签自动化分类方法及系统

    公开(公告)号:CN118296481A

    公开(公告)日:2024-07-05

    申请号:CN202310014831.3

    申请日:2023-01-05

    Abstract: 本发明提供了一种工业数据资产标签自动化分类方法和系统,包括:分类模型训练环节、数据分类应用环节。本发明基于概率密度函数,结合长期记忆向量设计了针对连续值特征属性的标签自动化分类架构,并采用混合采样技术解决样本类别分布不平衡的问题,实现工业中普遍存在的非均衡样本下的连续值数据资产的标签自动分类效果。本发明能够广泛应用于工业场景中针对受多个连续值特征影响的数据多标签自动化分类场景。

    工业互联网物联网的控制方法和系统

    公开(公告)号:CN118295283A

    公开(公告)日:2024-07-05

    申请号:CN202310011966.4

    申请日:2023-01-05

    Abstract: 本发明提供了一种工业互联网物联网的控制方法和系统,包括:工业互联网物联网模型通用的传感器数据快照获取的步骤;工业互联网物联网模型通用的设备控制的步骤;工业互联网物联网模型通用的传感器历史数据获取的步骤;工业互联网物联网模型通用的报警事件处理的步骤。本发明减少了开发和维护成本,开发者只需要遵循物联网模型的统一的标准的接口,此外使得所有的工业互联网应用都能快速的接入物联网设备,能充分挖掘物联网设备采集数据的价值。

    可配置规则化日志切分与报警监控的系统及方法

    公开(公告)号:CN116028294A

    公开(公告)日:2023-04-28

    申请号:CN202111240662.2

    申请日:2021-10-25

    Abstract: 本发明提供了一种可配置规则化日志切分与报警监控的系统及方法,包括:模块M1:在日志收集任务时,配置日志源,基于配置的日志源抓取原始日志;模块M2:在日志切分任务时,将抓取的原始日志根据日志清洗规则进行日志切分;模块M3:在配置告警任务时,选择切分后的日志,并配置告警规则以及告警对象,从而实现了一个或多个相关联的报警任务。本发明可以自定义监控系统运行的日志,自定义日志切分规则、设定报警规则,并发送告警信息。保障了相关人员对系统的自动化监控,以及对问题的及时响应和排查。

    跨子系统的空间任务依赖调度方法与系统

    公开(公告)号:CN115756783A

    公开(公告)日:2023-03-07

    申请号:CN202211434272.3

    申请日:2022-11-16

    Abstract: 本发明提供了一种跨子系统的空间任务依赖调度方法和系统,包括:在工作流上配置事件触发器,将多个事件触发器归属到一个调度拓扑模板中;在拓扑调度触发后获取归属于它的所有触发器,解析成一个跨空间流依赖拓扑关系,并找到起点工作流进行调度;使用消息总线机制实现跨工作空间流依赖拓扑关系的上下游工作流依赖通知;建立分布式内存总线机制,对消息总线进行抽象使用SPI机制实现TSS平台与消息列队服务以及相应的消费逻辑解耦,实现插件化消息列队服务。本发明最大程度体现了分布式算力在面对业务体量增长时的横向扩展机制,支持动态增加集群调度节点应对业务压力,基于算法自动计算生成拓扑依赖关系解决任务流程间复杂的编排调度问题。

Patent Agency Ranking