-
公开(公告)号：CN110019085A
公开(公告)日：2019-07-16
申请号：CN201711046071.5
申请日：2017-10-31
Applicant: 上海宝信软件股份有限公司
IPC: G06F16/182 , G06F16/22 , G06F16/27 , G06F16/25
Abstract: 本发明提供了一种基于HBase的分布式时序数据库，存储结构为三元组：TagID，Timestamp，TagVTQ；分布式时序数据库中的分布式文件数据库HBase的行键由TagID和BaseTime组成，BaseTime＝Timestamp/TimeSpan，TimeSpan为分布式时序数据库的行时间跨度，HBase的列族中每个HBase单元格保存至少一个TagVTQ。本发明可有效的解决传统的实时数据库在应对工业大数据在可靠性、扩展性、检索和其上的计算支撑能力的不足，有效地提升企业的智能化和信息化水平。
-
公开(公告)号：CN107766147A
公开(公告)日：2018-03-06
申请号：CN201610712300.1
申请日：2016-08-23
Applicant: 上海宝信软件股份有限公司
CPC classification number: G06F9/5088 , G06F17/30575 , G06F2209/5017
Abstract: 本发明提供了一种分布式的数据分析任务调度系统，包括：分布式数据存储服务模块、基于资源的分布式任务调度引擎模块、分布式消息队列模块、分布式应用程序协调服务模块、自动执行引擎模块。本发明提出了一种利用R语言进行数据分析的分布式任务调度架构，利用资源管理平台实现分布式资源管理，进而实现R语言分析的分布式调度执行；利用自动调度引擎，实现数据分片的任务自动调用，符合工业过程数据跟踪的自动化分析需求。
-
公开(公告)号：CN116010452A
公开(公告)日：2023-04-25
申请号：CN202111226614.8
申请日：2021-10-21
Applicant: 上海宝信软件股份有限公司
IPC: G06F16/2455 , G06F16/215 , G06F16/23 , G06F16/242 , G06F16/28 , G06F16/27 , G06F16/17 , G06F16/172 , G06F16/174 , G06F16/182
Abstract: 本发明提供了一种基于流式计算引擎的数据处理系统，包括数据采集模块：通过从终端采集获取原始数据后，同步编制发送端与接收端的编解码协议，从无界数据流中匹配对应的表信息完成对信息事件的采集；前置过滤模块：将采集筛选出的信息经由布隆过滤器提供的轻量级数据过滤，同步利用K‑V存储提供的海量数据过滤；数据预处理模块：流式计算引擎提供流批统一流处理，避免离线与实时两套业务开发产生的资源浪费，并且通过提供SQL支持对数据流向进行抽象；数据血缘模块：通过流式计算引擎提供的SQL抽象处理，采用SQL语言编写脚本描述数据的流向，再提交到平台上解析启动作业。本发明实现了对数据价值的挖掘以及对非结构化数据的处理分析。
-
公开(公告)号：CN115718782A
公开(公告)日：2023-02-28
申请号：CN202110968710.3
申请日：2021-08-23
Applicant: 上海宝信软件股份有限公司
IPC: G06F16/27 , G06Q10/0639 , G06Q30/018
Abstract: 本发明提供了一种工业数据生态的管理方法，其特征在于，包括如下步骤建立工业数据资产编码标准；按照工业数据资产编码标准自动为工业数据资产分配编码，并存储于区块链，所有的入湖数据都携带唯一的数据资产编码；通过唯一的数据资产编码来全流程记录数据转化为数据服务的过程，并存储于区块链；在集成共享和开放共享数据时，自动携带唯一的数据资产编码对数据资产进行全生命周期追溯，掌控数据资产的数据质量，做到全流程可信；在对接工业互联网时，对信息资源进行集成开放共享。本发明通过管理信息流的流转过程，掌控数据资产的流向，解决了数据冗余和信息孤岛的问题，实现了数据可信、过程可信和结果可信。
-
公开(公告)号：CN114579326A
公开(公告)日：2022-06-03
申请号：CN202011382758.8
申请日：2020-12-01
Applicant: 上海宝信软件股份有限公司
Abstract: 本发明提供了一种分布式作业调度和执行系统插件化的方法及系统，方法包括：包括：插件配置管理步骤、插件任务配置管理步骤、插件版本管理步骤、插件缓存管理步骤、任务触发执行管理步骤和插件任务执行步骤。本发明已经在工业互联网平台xIn3Plat中得到实现，实现了定制化业务作业的执行，本发明已经在多个数据治理项目中得以使用，在保障了分布式作业调度和执行系统稳定性可靠性的前提下，有效解决了分布式作业调度和执行系统轻松满足各种复杂且频繁变更的业务需求的场景，在今后任何应用xIn3Plat的项目中，都可以应用本发明。
-
Patent Agency Ranking
公开(公告)号：CN107229639B
公开(公告)日：2020-07-28
申请号：CN201610174008.9
申请日：2016-03-24
Applicant: 上海宝信软件股份有限公司
IPC: G06F16/27 , G06F16/182
Abstract: 本发明提供了一种分布式实时数据库的存储系统，包括：分布式数据网关模块：用于数据的接收与查询代理；分布式消息队列模块：用于通过分布式消息队列实现数据的发布与订阅；分布式实时流计算服务模块：用于基于storm实时流计算框架，实现消息订阅服务、内存快照存储服务以及持久化存储服务；分布式缓存服务模块：用于通过分布式缓存存储数据快照；分布式存储服务模块：通过Nosql数据库HBase进行分布式存储服务，通过分布式搜索引擎Solr实现数据的检索。本发明有效地提升企业的智能化和信息化水平，并利用大数据技术挖掘潜在的数据价值，为企业的转型发展提供坚实的数据基础。
-
公开(公告)号：CN104978264A
公开(公告)日：2015-10-14
申请号：CN201410141000.3
申请日：2014-04-09
Applicant: 上海宝信软件股份有限公司
IPC: G06F11/36
Abstract: 本发明提供了一种组态软件中图库精灵的动态调试方法，包括步骤：步骤1：设计和制作图库精灵；步骤2：对步骤1中制作得到的图库精灵进行调试；步骤3：调整和修改图库精灵；步骤4：完成图库精灵设计并保存成果。本发明为用户带来的是全新的使用体验，减少了测试过程的时间花费，提高了工作效率，能够广泛应用于安全生产、信息集成及掌控、辅助调度指挥等领域中的一体化监控平台系统中，有助于提高工程实施人员在建设和运营维护工作中进行自动化工程管理的效率。
-
公开(公告)号：CN112749160B
公开(公告)日：2024-12-27
申请号：CN201911063015.1
申请日：2019-10-31
Applicant: 上海宝信软件股份有限公司
IPC: G06F16/22 , G06F16/2458 , G06F16/27
Abstract: 本发明提供了一种面向工业4.0的时空大数据分布式存储检索方法，其特征在于，包括：数据接收步骤：接收窄带物联网实时产生的时空大数据；时空大数据图层存储步骤：将时空大数据图层存储到ElasticSearch中；时空大数据图层检索步骤：对时空大数据图层进行检索；时空大数据存储步骤：将时空大数据存储到ElasticSearch中；时空大数据检索步骤：在ElasticSearch中检索时空大数据；时空过程大数据存储步骤：将时空过程大数据存储到ElasticSearch中；时空过程大数据检索步骤：在ElasticSearch中检索时空过程大数据。本发明充分利用ElasticSearch实时搜索的高性能，极大的提高了时空大数据存储及检索性能。
-
公开(公告)号：CN118869836A
公开(公告)日：2024-10-29
申请号：CN202410556007.5
申请日：2024-05-07
Applicant: 上海宝信软件股份有限公司
Abstract: 本发明提供了一种跨通讯协议安全调用的工业互联网服务方法及系统，包括：服务调用者发起服务调用请求，并根据服务名获取服务的元数据；根据元数据中的通讯协议类型判断调用方和被调用方是否使用相同的通讯协议，若是，则将统一的标准数据交换格式转换成调用方所使用的通讯协议对应的格式，并向提供方发送服务调用请求，接收提供方发送的服务调用响应，将服务调用的响应转换成统一的标准数据交换格式返回给调用者；若否，则按照统一的标准数据交换格式，向服务总线发送服务调用请求，接收服务总线发送的服务调用响应，并返回给调用者。本发明简化了开发，减少了维护成本，还避免了不同通讯协议依赖的第三方开发包冲突的问题。
-
公开(公告)号：CN118860269A
公开(公告)日：2024-10-29
申请号：CN202410102498.6
申请日：2024-01-24
Applicant: 上海宝信软件股份有限公司
IPC: G06F3/06 , G06F9/455 , G06F9/50 , G06F16/22 , G06F16/182
Abstract: 本发明提供了一种租户级别资源隔离的数据写入通道管理方法和系统，包括：步骤1：部署负载均衡集群；步骤2：进行多租户隔离；步骤3：数据通过Rest网关写入后，被送到数据缓存层，然后通过Spark Streaming程序消费并写入HDFS，将数据缓存层和Spark Streaming程序的组合作为数据写入通道；步骤4：设置消费组和消费实例，从而改变数据消费速度；步骤5：部署文件合并服务，负责监控文件数量和大小，当文件个数或大小达到预设阈值，则自动触发小文件合并。本发明可以按需配置计算资源，提高了数据吞吐量和写入的效率，支持租户级别的资源隔离配置。
-
-
-
-
-
-
-
-
-
Search Results
33
records
(took 0.164 seconds)
