基于流式计算引擎的工业数据监控系统和方法、介质

    公开(公告)号:CN116009428A

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

    申请号:CN202111228109.7

    申请日:2021-10-21

    Abstract: 本发明提供了一种基于流式计算引擎的工业数据监控系统,包括状态监控模块采用流式计算引擎原生支持的Prometheus进行实时指标采集和存储,通过meta节点定时抓取所有子节点指标进行汇总,统一数据源提供给Grafana进行可视化并通过dashboard进行告警配置;资源调配模块对实时任务进行分析提供足够的内存给作业,同时对任务消息进行实时处理,结合实时任务内存分析所得相关指标、实时任务并发度的合理性,得出实时任务资源预设值,调整实时任务资源,达到实时任务资源配置;异常状态模块利用SideOutput来收集流式作业各环节中出错的数据,汇总到统一的错误流,通过在流式数据中发现符合设定特征的模式进行实时告警。本发明将复杂事件处理与流式计算引擎结合,能增强告警的实时性和适用范围。

    工业算法平台化系统和方法
    22.
    发明公开

    公开(公告)号:CN115712483A

    公开(公告)日:2023-02-24

    申请号:CN202110949379.0

    申请日:2021-08-18

    Abstract: 本发明提供了一种工业算法平台化系统和方法,包括:步骤1:创建虚拟环境;步骤2:根据用户需求对虚拟环境构建配置;步骤3:根据虚拟环境构建配置生成虚拟环境镜像;步骤4:根据执行算法请求生成算法运行配置,触发运行环境中异步执行算法程序,生成算法实例并记录对应的运行环境和异步执行句柄;步骤5:根据算法运行配置,使用虚拟环境镜像异步执行算法并返回异步执行句柄,并提供异步执行句柄状态查询;步骤6:进行算法探索、开发和测试,生成算法程序,在运行环境中运行并反馈结果至用户。本发明有效解决了工业数据智能化过程中,各种分析挖掘预测算法运行依赖复杂且相互之间干扰冲突的问题。

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

    公开(公告)号:CN118296481A

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

    申请号:CN202310014831.3

    申请日:2023-01-05

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

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

    公开(公告)号:CN118295283A

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

    申请号:CN202310011966.4

    申请日:2023-01-05

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

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

    公开(公告)号:CN115756783A

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

    申请号:CN202211434272.3

    申请日:2022-11-16

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

    基于元数据的时空大数据REST微服务数据交互方法和系统

    公开(公告)号:CN114979189A

    公开(公告)日:2022-08-30

    申请号:CN202110189292.8

    申请日:2021-02-19

    Abstract: 本发明提供了一种基于元数据的时空大数据REST微服务数据交互方法,利用时空大数据分布式REST微服务返回的JSON数据包包括操作数据、路由数据、请求数据和响应数据;操作数据包括GETMETA操作数据和GETDATA操作数据,通过路由数据使用GETMETA操作数据发送请求数据获取元数据信息,GETDATA操作数据根据响应数据获取时空大数据;路由数据标识工业互联网系统和时空大数据REST微服务,包括源地址数据和目标地址数据。本发明解决了时空大数据REST微服务的调用端无法智能识别时空大数据REST服务返回数据的语义的技术问题,同时,解决了在工业互联网系统内以及跨工业互联网系统提供统一方法访问时空大数据REST服务的技术问题。

    与web会话解耦注入上下文信息的服务调用系统及方法

    公开(公告)号:CN102480464A

    公开(公告)日:2012-05-30

    申请号:CN201010556912.9

    申请日:2010-11-24

    Abstract: 本发明公开了一种与web会话解耦自动注入用户上下文信息的服务调用系统及方法。该系统包括:服务调用客户端,服务调度总控模块,一组被调用的服务。该方法包括:用户发起web请求调用后台服务;获取用户配置的上下文同步信息项;将web会话信息中需要同步的信息项数据同步至用户上下文信息令牌中;将用户上下文信息令牌注入后台服务供使用;服务调用,服务代码使用并维护用户上下文信息令牌中的相关信息;监控是否发生用户上下文信息令牌的修改;将发生修改的用户上下文信息令牌中的信息项数据同步至web会话中;web请求调用返回。本发明确保后台核心代码与web层的完全解耦,保证核心业务逻辑在不同技术路线下的可复用性。

    工业数据生态的管理方法和系统、设备、可读介质

    公开(公告)号:CN115718782A

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

    申请号:CN202110968710.3

    申请日:2021-08-23

    Abstract: 本发明提供了一种工业数据生态的管理方法,其特征在于,包括如下步骤建立工业数据资产编码标准;按照工业数据资产编码标准自动为工业数据资产分配编码,并存储于区块链,所有的入湖数据都携带唯一的数据资产编码;通过唯一的数据资产编码来全流程记录数据转化为数据服务的过程,并存储于区块链;在集成共享和开放共享数据时,自动携带唯一的数据资产编码对数据资产进行全生命周期追溯,掌控数据资产的数据质量,做到全流程可信;在对接工业互联网时,对信息资源进行集成开放共享。本发明通过管理信息流的流转过程,掌控数据资产的流向,解决了数据冗余和信息孤岛的问题,实现了数据可信、过程可信和结果可信。

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

    公开(公告)号:CN114579326A

    公开(公告)日:2022-06-03

    申请号:CN202011382758.8

    申请日:2020-12-01

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

Patent Agency Ranking