-
公开(公告)号：CN118535624A
公开(公告)日：2024-08-23
申请号：CN202410539385.2
申请日：2024-04-30
申请人： 郑州恒达智控科技股份有限公司 , 郑州煤机智控技术创新中心有限公司
IPC分类号： G06F16/25 , G06F16/23 , G06F16/2455 , G06F16/2458
摘要： 本发明提供一种让Flink可以读写Tdengine的方法，包括Source模块、Sink模块和公共模块，通过Source模块读取数据，并将数据发送到Flink的数据流中，通过公共模块提供数据结构转换器和Tdengine连接器，数据结构转换器对数据流中的数据进行转换处理，转换处理后的数据由Sink进行批量处理，并将批量处理后需要存储的数据存储到Tdengine中。本发明提供的让Flink可以读写Tdengine的方法能够在企业级的Flink生产环境中进行使用，其支持实时的source和sink，同时支持Table API/Flink SQL和DataStream API，checkpoint和savepoint的状态恢复，其中sink中支持upsert，并动态支持tdengine扩容缩容。
-
公开(公告)号：CN118855512A
公开(公告)日：2024-10-29
申请号：CN202411064340.0
申请日：2024-08-05
申请人： 郑州恒达智控科技股份有限公司 , 郑州煤机智控技术创新中心有限公司
IPC分类号： E21D15/46 , E21F17/18 , G08B25/08 , H04L65/65 , H04L67/02 , H04L67/12 , H04W4/38 , G06N20/00
摘要： 本发明公开了基于煤矿行业的液压支架支护质量综合监测方法及系统；所述监测方法包括以下步骤：S1、开始；S2、查询配置信息数据并将数据接入；S3、选择是否接入视频；S4、数据接入后通过算法判断安全风险并告警；S5、对传感器数据进行解析并进行展示，同时将告警信息发送至矿方手机；S6、结束。所述监测系统包括用于进行视频或数据信息可视化的展示层、用于获取数据并实现网络通讯传输的通讯层、用于进行数据分析处理的逻辑层、用于存储解析数据的数据层；展示层的信号端经通讯层与逻辑层的信号端相连接，逻辑层的信号端分别与展示层、数据层的信号端相连接。
-
公开(公告)号：CN118132241A
公开(公告)日：2024-06-04
申请号：CN202410404510.9
申请日：2024-04-07
申请人： 郑州恒达智控科技股份有限公司 , 郑州煤机智控技术创新中心有限公司
摘要： 本发明公开了一种基于Tdengine的数据迁移系统及方法，涉及数据迁移技术领域，包括配置管理模块、分片管理单元、线程调度单元、结构转换单元、日志管理单元、异常管理单元；首先系统初始化配置管理模块并读取配置信息，获取所有的超级表并以各个超级表的起始时间开始创建线程任务，之后启动线程迁移任务，并对迁移过程进行实时监控。该系统在数据迁移过程中结合了表结构改造、分布式部署、多线程并发执行、实时监控和重跑等多种功能，极大地提高了数据迁移的效率和可靠性；同时这些功能也为操作人员提供了更好的管理和控制手段，使得数据迁移过程更加可靠和高效。
-
公开(公告)号：CN116933444A
公开(公告)日：2023-10-24
申请号：CN202311026452.2
申请日：2023-08-15
申请人： 郑州恒达智控科技股份有限公司
摘要： 本发明公开了一种新型液压支架技术协议快速配套方法及系统，涉及液压支架技术协议配套技术领域，包括首先对用户信息进行管理登记，再在系统的快速配套模块进行液压支架技术协议的快速配套，即用户根据选定的关于支架的关键参数项并输入期望值内容，通过平均加权的方法计算得分比例，通过系统与标准架型的匹配生成最优的推荐架型，用户根据该推荐架型再适应性调整参数值，最终确认无误后即可完成本次液压支架的协议配套。本发明大大提高液压支架设计和配套的效率，节省时间和成本，同时也提高了系统的可靠性和用户的满意度。
-
-
-
搜索结果
4 条记录 (耗时 0.084 秒)
