本发明涉及光伏电站，特别涉及一种光伏电站数据处理方法、采集方法、装置及系统。
背景技术：
1、随着光伏能源行业的快速发展，光伏电站的建设数量不断增加，规模不断扩大。为满足高效、智能监控管理的需求，如何实时、准确地监测和控制光伏电站的运行数据采集成为重要的研究课题。
2、光伏电站数据采集监控技术在此背景下应运而生。该技术需要安装数据采集和监测设备，所述数据采集器实时采集光伏电站的各项数据，如温度、光照强度、电压、电流、功率等，并将采集到的数据远程传输到数据处理中心进行分析和处理。所述监测设备通过对数据进行实时监测和分析，可以评估光伏电站的运行状态和效率，及时发现和解决潜在问题，优化发电效率，降低能耗和成本。
3、目前，由于光伏电站数据时效性不需太高，所述数据采集器通常使用第四代移动通信技术(the 4th generation mobile communication technology，4g)，远程或有线传输光伏电站数据到数据网关，进而传输至数据处理中心。所述数据采集器与数据网关之间通常使用传统的104通讯协议进行通讯，并且采用一问一答的数据传输模式。但是这种数据传输方式在处理大量遥信、遥测数据的情况下，可能会导致处理不及时出现丢包的问题。
4、并且，由于不同数据采集器采集到的光伏电站数据的数据格式会有一定区别，需要在数据采集过程中间某个环节进行统一格式处理，实现方法复杂且通用性和兼容性较差。
技术实现思路
1、针对现有技术的上述问题，本发明的目的在于提供一种光伏电站数据处理方法、采集方法、装置及系统，能够适用于不同类型的数据采集器，通用性和兼容性较好。
2、为了解决上述问题，本发明提供一种光伏电站数据处理方法，应用于光伏电站数据采集系统中的业务服务模块，包括：
3、获取待处理的光伏电站数据，确定所述光伏电站数据的数据格式，所述数据格式包括单层数据格式和多层嵌套格式；
4、根据所述数据格式确定对所述光伏电站数据进行处理的目标处理策略；
5、基于所述目标处理策略对所述光伏电站数据进行处理，得到并存储处理后的数据。
6、进一步地，所述根据所述数据格式确定对所述光伏电站数据进行处理的目标处理策略，包括：
7、若所述数据格式为单层数据格式，确定所述目标处理策略为第一处理策略；
8、若所述数据格式为三层嵌套格式，确定所述目标处理策略为第二处理策略；
9、若所述数据格式为四层嵌套格式，确定所述目标处理策略为第三处理策略。
10、进一步地，所述基于所述目标处理策略对所述光伏电站数据进行处理，得到并存储处理后的数据，包括：
11、若所述目标处理策略为第二处理策略，确定所述光伏电站数据对应的设备类型；
12、根据所述设备类型确定所述光伏电站数据对应的第一dto模型表；
13、对所述光伏电站数据进行分割遍历，获取第一解析数据并填充至所述第一dto模型表中；
14、基于所述第一dto模型表更新mysql数据库中对应的实时数据表；
15、将所述第一解析数据封装为第一map集合，并将所述第一map集合存储至influxdb时序库中。
16、进一步地，所述基于所述目标处理策略对所述光伏电站数据进行处理，得到并存储处理后的数据，包括：
17、若所述目标处理策略为第三处理策略，获取所述光伏电站数据对应的第二dto模型表；
18、对所述光伏电站数据进行分层遍历，获取第二解析数据并填充至所述第二dto模型表中；
19、基于所述第二dto模型表更新mysql数据库中对应的实时数据表；
20、将所述第二解析数据封装为第二map集合，并将所述第二map集合存储至influxdb时序库中。
21、本发明另一方面提供一种光伏电站数据采集方法，应用于光伏电站数据采集系统，所述系统包括多个数据采集器、kafka集群以及业务服务模块，所述方法包括：
22、所述数据采集器采集光伏电站内的设备数据，并将所述设备数据打包成预设数据格式的光伏电站数据，所述预设数据格式包括单层数据格式和多层嵌套格式；
23、所述数据采集器将所述光伏电站数据发送至所述kafka集群；
24、所述kafka集群接收并将所述光伏电站数据存储至所述光伏电站对应的目标主题中，所述目标主题为自定义的kafka消息队列；
25、所述业务服务模块获取所述目标主题中的所述光伏电站数据，并采用如上述的光伏电站数据处理方法对所述光伏电站数据进行处理。
26、进一步地，所述数据采集器将所述光伏电站数据发送至所述kafka集群，包括：
27、所述数据采集器将所述光伏电站数据发送至第三方服务端，通过所述第三方服务端将所述光伏电站数据转发至所述kafka集群。
28、进一步地，所述系统还包括配置中心；
29、所述方法还包括：
30、所述配置中心响应于用户针对所述光伏电站的主题配置请求，为所述光伏电站配置一个或多个主题，并在web端呈现所述一个或多个主题；
31、所述第三方服务端为各个所述主题配置对应的数据转发规则。
32、进一步地，所述业务服务模块获取所述目标主题中的所述光伏电站数据，包括：
33、当监听到所述目标主题中出现新数据时，所述业务服务模块通过调用所述kafka集群中的一个kafka节点，获取所述目标主题中的所述光伏电站数据。
34、本发明另一方面提供一种光伏电站数据处理装置，所述装置设置于光伏电站数据采集系统中的业务服务模块，所述装置包括：
35、格式确定模块，用于获取待处理的光伏电站数据，确定所述光伏电站数据的数据格式，所述数据格式包括单层数据格式和多层嵌套格式；
36、策略确定模块，用于根据所述数据格式确定对所述光伏电站数据进行处理的目标处理策略；
37、数据处理模块，用于基于所述目标处理策略对所述光伏电站数据进行处理，得到并存储处理后的数据。
38、本发明另一方面提供一种光伏电站数据采集系统，所述系统包括多个数据采集器、kafka集群以及业务服务模块；
39、所述数据采集器，用于采集光伏电站内的设备数据，并将所述设备数据打包成预设数据格式的光伏电站数据，所述预设数据格式包括单层数据格式和多层嵌套格式；将所述光伏电站数据发送至所述kafka集群；
40、所述kafka集群，用于接收并将所述光伏电站数据存储至所述光伏电站对应的目标主题中，所述目标主题为自定义的kafka消息队列；
41、所述业务服务模块，用于获取所述目标主题中的所述光伏电站数据，并采用如上述的光伏电站数据处理方法对所述光伏电站数据进行处理。
42、本发明另一方面提供一种电子设备，包括处理器和存储器，所述存储器中存储有至少一条指令或至少一段程序，所述至少一条指令或所述至少一段程序由所述处理器加载并执行以实现如上述的光伏电站数据处理方法或光伏电站数据采集方法。
43、本发明另一方面提供一种计算机可读存储介质，所述计算机可读存储介质中存储有至少一条指令或至少一段程序，所述至少一条指令或所述至少一段程序由处理器加载并执行以实现如上述的光伏电站数据处理方法或光伏电站数据采集方法。
44、本发明另一方面提供一种计算机程序产品，包括计算机程序/指令，该计算机程序/指令被处理器执行时实现如上述的光伏电站数据处理方法或光伏电站数据采集方法。
45、由于上述技术方案，本发明具有以下有益效果：
46、根据本发明实施例的光伏电站数据处理方法，通过预先设置不同的数据处理策略，来分别处理单层数据格式和多层嵌套格式的光伏电站数据，无需对光伏电站数据进行统一格式处理，实现方法简单，且能够适用于不同类型的数据采集器，通用性和兼容性较好。
47、根据本发明实施例的光伏电站数据采集方法，通过使用发布/订阅消息模式，将采集到的光伏电站数据存储至kafka集群等待消费，并通过预先设置不同的数据处理策略，来分别处理单层数据格式和多层嵌套格式的光伏电站数据，无需对光伏电站数据进行统一格式处理，实现方法简单，能够高效采集和处理海量光伏电站数据，避免处理不及时出现丢包的问题，并且能够适用于不同类型的数据采集器，通用性和兼容性较好。
1.一种光伏电站数据处理方法，应用于光伏电站数据采集系统中的业务服务模块，其特征在于，所述方法包括：
2.根据权利要求1所述的方法，其特征在于，所述根据所述数据格式确定对所述光伏电站数据进行处理的目标处理策略，包括：
3.根据权利要求2所述的方法，其特征在于，所述基于所述目标处理策略对所述光伏电站数据进行处理，得到并存储处理后的数据，包括：
4.根据权利要求2所述的方法，其特征在于，所述基于所述目标处理策略对所述光伏电站数据进行处理，得到并存储处理后的数据，包括：
5.一种光伏电站数据采集方法，其特征在于，应用于光伏电站数据采集系统，所述系统包括多个数据采集器、kafka集群以及业务服务模块，所述方法包括：
6.根据权利要求5所述的方法，其特征在于，所述数据采集器将所述光伏电站数据发送至所述kafka集群，包括：
7.根据权利要求6所述的方法，其特征在于，所述系统还包括配置中心；
8.根据权利要求5所述的方法，其特征在于，所述业务服务模块获取所述目标主题中的所述光伏电站数据，包括：
9.一种光伏电站数据处理装置，其特征在于，所述装置设置于光伏电站数据采集系统中的业务服务模块，所述装置包括：
10.一种光伏电站数据采集系统，其特征在于，所述系统包括多个数据采集器、kafka集群以及业务服务模块；
