一种故障数据处理方法及终端与流程

1.本发明涉及故障处理技术领域，特别涉及一种故障数据处理方法及终端。


背景技术：

2.光储充电站需要保证所运营的所有模块的健康度，所以会对模块状态进行采集，对非健康或数据异常的模块会进行告警，在模块恢复正常之前会产生大量的故障数据，故障数据如何存储和怎么做到快速检索对其追踪分析起着至关重要的作用。
3.在模块故障期间，故障数据会持续上传，导致一个故障会产生海量的数据。对此，传统的做法中是将其数据储存到关系型数据库，例如mysql，然后再对其进行分库分表，根据故障的上传间隔去确定一条故障。但是，即便是对数据库进行分库分表对于搜索海量数据来说也会导致搜索变慢，并且数据难以管理。
4.在这种情况下，用户在查询故障的时候时最终得到的应该是合并后的数据，但实际上查询的时候需要把所有数据都查询出来，由于是海量数据，这样会导致关系型数据库压力激增。即便是看原始的物联数据的话也会对关系型数据库造成较大的压力，难以实现快速检索想要的故障数据。


技术实现要素：

5.本发明所要解决的技术问题是：提供一种故障数据处理方法及终端，在存储故障数据时不仅能够减轻数据库的压力，还便于后期快速检索故障数据。
6.为了解决上述技术问题，本发明采用的技术方案为：
7.一种故障数据处理方法，包括步骤：
8.s1、实时接收来自设备的故障上报信息和故障明细数据；
9.s2、在接收到所述故障上报信息的同时将所述故障上报信息中的故障时间和所属设备写入搜索引擎库；
10.s3、将所述故障明细数据写入时序数据库。
11.为了解决上述技术问题，本发明采用的另一种技术方案为：
12.一种故障数据处理终端，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，所述处理器执行所述计算机程序时实现以下步骤：
13.s1、实时接收来自设备的故障上报信息和故障明细数据；
14.s2、在接收到所述故障上报信息的同时将所述故障上报信息中的故障时间和所属设备写入搜索引擎库；
15.s3、将所述故障明细数据写入时序数据库。
16.本发明的有益效果在于：提供一种故障数据处理方法及终端，在设备发生故障时，将设备发出的故障上报信息中的故障时间和所属设备写入搜索引擎库中，将设备在故障期间所不断产生的故障明细数据写入时序数据库中，在用户需要查看故障数据的时候可查询搜索引擎库，以便于快速得到搜索结果，在用户想要查看故障详情数据时可使用时序数据
库进行查询，依靠时序数据库的超强性能以及压缩能力，会使得海量数据的查询以及分析变的更快，从而在存储故障数据时不仅能够减轻数据库的压力，还便于后期快速检索故障数据。
附图说明
17.图1为本发明的一种故障数据处理方法的流程示意图；
18.图2为现有的故障处理架构图；
19.图3为本发明实施例涉及的故障处理架构图；
20.图4为本发明实施例的一种故障数据处理终端的结构示意图。
21.标号说明：
22.1、一种故障数据处理终端；2、处理器；3、存储器；4、设备；5、网关；6、关系型数据库；7、用户端；8、搜索引擎库；9、时序数据库。
具体实施方式
23.为详细说明本发明的技术内容、所实现目的及效果，以下结合实施方式并配合附图予以说明。
24.请参照图1和图3，一种故障数据处理方法，包括步骤：
25.s1、实时接收来自设备4的故障上报信息和故障明细数据；
26.s2、在接收到所述故障上报信息的同时将所述故障上报信息中的故障时间和所属设备写入搜索引擎库8；
27.s3、将所述故障明细数据写入时序数据库9。
28.从上述描述可知，本发明的有益效果在于：提供一种故障数据处理方法及终端，在设备4发生故障时，将设备4发出的故障上报信息中的故障时间和所属设备写入搜索引擎库8中，将设备4在故障期间所不断产生的故障明细数据写入时序数据库9中，在用户需要查看故障数据的时候可查询搜索引擎库8，以便于快速得到搜索结果，在用户想要查看故障详情数据时可使用时序数据库9进行查询，依靠时序数据库9的超强性能以及压缩能力，会使得海量数据的查询以及分析变的更快，从而在存储故障数据时不仅能够减轻数据库的压力，还便于后期快速检索故障数据。
29.进一步地，所述步骤s2还包括：
30.将所述故障时间和所属设备存储至缓存区并发送故障通知给用户端7。
31.从上述描述可知，将故障时间和所属设备存储至缓存区，以便于对此次故障期间的所有故障上报信息进行统计，将包括故障时间和所属设备的故障通知发送给用户端7，便于用户提前了解故障的一些大致情况。
32.进一步地，所述步骤s3之后还包括：
33.s4、实时判断是否接收到故障恢复通知，若是，则整合所述缓存区内在此次故障期间内的所有所述故障时间和所属设备以及所述故障恢复通知，得到已恢复故障设备信息并更新所述搜索引擎库8，否则继续执行所述步骤s1。
34.从上述描述可知，从收到第一条故障上报信息起，即意味着进入故障期间；在收到故障恢复通知时说明退出故障期间，将故障期间内的所有故障时间和所属设备与最后的故
障恢复通知进行整合，得到已恢复故障设备信息并更新搜索引擎库8中，以便于以用户后续检索时可直接概览单次故障期间的故障信息并了解该次故障的恢复情况。
35.进一步地，所述故障通知包括链接所述搜索引擎库8的检索窗口的查询按钮。
36.从上述描述可知，在发送故障通知的同时提供查询按钮，便于用户直接查询搜索引擎库8的存储内容，了解故障详情。
37.进一步地，s3具体为：
38.以所述所属设备为分类依据，将所述故障明细数据写入至所述时序数据库9。
39.从上述描述可知，将故障设备4的故障明细数据分类汇总存放，在用户查询数据时，能够提高搜索效率。
40.请参照图4，一种故障数据处理终端1，包括存储器3、处理器2及存储在存储器3上并可在处理器2上运行的计算机程序，所述处理器2执行所述计算机程序时实现以下步骤：
41.s1、实时接收来自设备4的故障上报信息和故障明细数据；
42.s2、在接收到所述故障上报信息的同时将所述故障上报信息中的故障时间和所属设备写入搜索引擎库8；
43.s3、将所述故障明细数据写入时序数据库9。
44.从上述描述可知，本发明的有益效果在于：提供一种故障数据处理方法及终端，在设备4发生故障时，将设备4发出的故障上报信息中的故障时间和所属设备写入搜索引擎库8中，将设备4在故障期间所不断产生的故障明细数据写入时序数据库9中，在用户需要查看故障数据的时候可查询搜索引擎库8，以便于快速得到搜索结果，在用户想要查看故障详情数据时可使用时序数据库9进行查询，依靠时序数据库9的超强性能以及压缩能力，会使得海量数据的查询以及分析变的更快，从而在存储故障数据时不仅能够减轻数据库的压力，还便于后期快速检索故障数据。
45.进一步地，所述步骤s2还包括：
46.将所述故障时间和所属设备存储至缓存区并发送故障通知给用户端7。
47.从上述描述可知，将故障时间和所属设备存储至缓存区，以便于对此次故障期间的所有故障上报信息进行统计，将故障时间和所属设备发送故障通知给用户端7，便于用户提前了解故障的一些大致情况。
48.进一步地，所述步骤s3之后还包括：
49.s4、实时判断是否接收到故障恢复通知，若是，则整合所述缓存区内在此次故障期间内的所有所述故障时间和所属设备以及所述故障恢复通知，得到已恢复故障设备信息并更新所述搜索引擎库8，否则继续执行所述步骤s1。
50.从上述描述可知，从收到第一条故障上报信息起，即意味着进入故障期间；在收到故障恢复通知时说明退出故障期间，将故障期间内的所有故障时间和所属设备与最后的故障恢复通知进行整合，得到已恢复故障设备信息并更新搜索引擎库8中，以便于以用户后续检索时可直接概览单次故障期间的故障信息并了解该次故障的恢复情况。
51.进一步地，所述故障通知包括链接所述搜索引擎库8的检索窗口的查询按钮。
52.从上述描述可知，在发送故障通知的同时提供查询按钮，便于用户直接查询搜索引擎库8的存储内容，了解故障详情。
53.进一步地，s3具体为：
54.以所述所属设备为分类依据，将所述故障明细数据写入至所述时序数据库9。
55.从上述描述可知，将故障设备4的故障明细数据分类汇总存放，在用户查询数据时，能够提高搜索效率。
56.本发明的一种故障数据处理方法及终端能够适用于故障时间和所属设备管理的场景，以下通过具体的实施方式进行说明：
57.请参照图1至图3，本发明的实施例一为：
58.以充电站为例，充电站的设备4的某些模块发生故障时，设备4会针对此故障生成故障上报信息并通过网关5进行上报，同时模块在故障期间会不断产生恢复正常之前会产生大量的故障明细数据，故障明细数据也会不断上传。
59.如图1所示，现有的故障处理架构将其数据储存到关系型数据库6，例如mysql，然后再对其进行分库分表，根据故障的上传间隔去确定一条故障。但是，即便是对数据库进行分库分表对于搜索海量数据来说也会导致搜索变慢，并且数据难以管理。
60.基于此，为了更好地存储管理这些数据，提高检索效率，本实施例的一种故障数据处理方法，包括步骤：
61.s1、实时接收来自设备4的故障上报信息和故障明细数据；
62.s2、在接收到故障上报信息的同时将故障上报信息中的故障时间和所属设备写入搜索引擎库8；
63.在本实施例中，故障上报信息中主要包含了故障时间和所属设备两大信息；为了便于区分，所属设备可使用唯一id表示每个设备4，从而可清楚展示故障来源。
64.在本实施例中，当接收到第一条故障上报信息时，可认为设备4已经处于故障期间，此时，将故障时间和所属设备存储至缓存区并发送故障通知给用户端7。用户端7及时得知设备4发生故障，从而可尽早进行恢复操作，以使得设备4脱离故障，正常运行。故障通知可通过分布式发布订阅消息系统，如kafka，发送至用户端7。
65.并且，故障通知包括链接所述搜索引擎库8的检索窗口的查询按钮。结合图3所示，用户通过点击推送的故障通知中的查询按钮时，即会去搜索引擎库8中直接查询故障上报信息；其中，若用户在故障恢复前进行查询，则所能检索到的就是已经写在搜索引擎库8内的故障上报信息；若用户在在故障恢复后进行查询，则查询到的是包括故障恢复通知和故障期间的所有的故障上报信息中的故障时间和所属设备在内的已恢复故障设备信息。另外，用户如需查看故障明细数据，亦可以以点击功能模块的方式查看故障明细数据，由后台去时序数据库9中将其对应的故障明细数据展示出来。
66.s3、将故障明细数据写入时序数据库9。
67.在本实施例中，在将故障明细数据写入时序数据库9之前，以所属设备为分类依据对故障明细数据进行处理，具体在接收到故障明细数据时，将其转发至实时计算程序flink上，由flink对其进行处理。
68.s4、实时判断是否接收到故障恢复通知，若是，则整合缓存区内在此次故障期间内的所有故障时间和所属设备以及故障恢复通知，得到已恢复故障设备信息并更新搜索引擎库8，否则继续执行步骤s1。
69.在本实施例中，在接收到故障恢复通知时，则说明该次故障期间的所所有故障设备均已被恢复，此时整合缓存区内在此次故障期间内的所有故障时间和所属设备以及故障
恢复通知，得到已恢复故障设备信息并更新搜索引擎库8，即将搜索引擎库8中对应单次故障期间所增加的所有故障时间和所属设备都整合在一起，成为一条由故障产生到故障恢复整个过程的完整信息并单独存放，降低搜索引擎库8的存储压力，还便于用户查询了解这些信息。
70.请参照图4，本发明的实施例二为：
71.一种故障数据处理终端1，包括存储器3、处理器2及存储在存储器3上并可在处理器2上运行的计算机程序，处理器2执行计算机程序时实现上述实施例一的步骤。
72.综上所述，本发明提供的一种故障数据处理方法及终端，在设备发生故障时，将设备发出的故障上报信息中的故障时间和所属设备写入搜索引擎库中，将设备在故障期间所不断产生的故障明细数据写入时序数据库中，在用户需要查看故障数据的时候可查询搜索引擎库，以便于快速得到搜索结果，在用户想要查看故障详情数据时可使用时序数据库进行查询，依靠时序数据库的超强性能以及压缩能力，会使得海量数据的查询以及分析变的更快，从而在存储故障数据时不仅能够减轻数据库的压力，还便于后期快速检索故障数据。
73.以上所述仅为本发明的实施例，并非因此限制本发明的专利范围，凡是利用本发明说明书及附图内容所作的等同变换，或直接或间接运用在相关的技术领域，均同理包括在本发明的专利保护范围内。

技术特征：
1.一种故障数据处理方法，其特征在于，包括步骤：s1、实时接收来自设备的故障上报信息和故障明细数据；s2、在接收到所述故障上报信息的同时将所述故障上报信息中的故障时间和所属设备写入搜索引擎库；s3、将所述故障明细数据写入时序数据库。2.根据权利要求1所述的一种故障数据处理方法，其特征在于，所述步骤s2还包括：将所述故障时间和所属设备存储至缓存区并发送故障通知给用户端。3.根据权利要求2所述的一种故障数据处理方法，其特征在于，所述步骤s3之后还包括：s4、实时判断是否接收到故障恢复通知，若是，则整合所述缓存区内在此次故障期间内的所有所述故障时间和所属设备以及所述故障恢复通知，得到已恢复故障设备信息并更新所述搜索引擎库，否则继续执行所述步骤s1。4.根据权利要求2所述的一种故障数据处理方法，其特征在于，所述故障通知包括链接所述搜索引擎库的检索窗口的查询按钮。5.根据权利要求1所述的一种故障数据处理方法，其特征在于，s3具体为：以所述所属设备为分类依据，将所述故障明细数据写入至所述时序数据库。6.一种故障数据处理终端，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，其特征在于，所述处理器执行所述计算机程序时实现以下步骤：s1、实时接收来自设备的故障上报信息和故障明细数据；s2、在接收到所述故障上报信息的同时将所述故障上报信息中的故障时间和所属设备写入搜索引擎库；s3、将所述故障明细数据写入时序数据库。7.根据权利要求6所述的一种故障数据处理终端，其特征在于，所述步骤s2还包括：将所述故障时间和所属设备存储至缓存区并发送故障通知给用户端。8.根据权利要求7所述的一种故障数据处理终端，其特征在于，所述步骤s3之后还包括：s4、实时判断是否接收到故障恢复通知，若是，则整合所述缓存区内在此次故障期间内的所有所述故障时间和所属设备以及所述故障恢复通知，得到已恢复故障设备信息并更新所述搜索引擎库，否则继续执行所述步骤s1。9.根据权利要求7所述的一种故障数据处理终端，其特征在于，所述故障通知包括链接所述搜索引擎库的检索窗口的查询按钮。10.根据权利要求6所述的一种故障数据处理终端，其特征在于，s3具体为：以所述所属设备为分类依据，将所述故障明细数据写入至所述时序数据库。

技术总结
本发明公开了一种故障数据处理方法及终端，实时接收来自设备的故障上报信息和故障明细数据；在接收到故障上报信息的同时将故障上报信息中的故障时间和所属设备写入搜索引擎库；将故障明细数据写入时序数据库。本发明在用户需要查看故障数据的时候可查询搜索引擎库，以便于快速得到搜索结果，在用户想要查看故障详情数据时可使用时序数据库进行查询，依靠时序数据库的超强性能以及压缩能力，会使得海量数据的查询以及分析变的更快，从而在存储故障数据时不仅能够减轻数据库的压力，还便于后期快速检索故障数据。后期快速检索故障数据。后期快速检索故障数据。


技术研发人员：黄春斌 林少中
受保护的技术使用者：福建时代星云科技有限公司
技术研发日：2023.04.21
技术公布日：2023/8/21