本发明涉及通信技术领域，尤其涉及一种数据采集和分析的方法及装置。
背景技术：
在标准定义的数据采集和分析框架中，数据分析流程是当其他网络网元(networkfunction，nf)或网络功能实体(即nwdaf服务消费者)向网络数据分析网元(networkdataanalyticsfunction，nwdaf)发起数据分析类型请求时，才会被触发。
但是，受制于当前网络状态以及内部的数据分析算法，nwdaf网元采集数据和分析数据所消耗的时间是不可控的。若nwdaf服务消费者需要较高的及时性时，则无法满足需求，降低用户体验。
技术实现要素：
本发明提供了一种数据采集和分析的方法及装置，用于改善无法保证数据分析的及时性的问题。
为达到上述目的，本发明采用如下技术方案：
第一方面，一种数据采集和分析方法，应用于通信网络数据分析网元，包括：通信网络数据分析网元注册网络功能网元服务，注册成功后，向数据源网元发送目标数据订阅指示；其中，所述目标数据订阅指示用于指示所述数据源网元在检测到目标数据满足目标订阅条件时，将所述目标数据发送给所述通信网络数据分析网元；当通信网络数据分析网元接收到所述数据源网元发送的目标数据；根据所述目标数据进行分析，得到分析结果。
本公开提供一种数据采集和分析方法，通信网络数据分析网元在网络存储库网元进行注册，注册成功后，通过数据源网元获取目标数据进行分析。通信网络数据分析网元通过注册在网络存储库网元存储基础信息，便于后续根据nwdaf服务消费者需求快速查找到对应的通信网络数据分析网元。注册成功后，及时获取数据并进行分析，输出分析结果。便于当系统接收到nwdaf服务消费者的请求后，迅速响应，立即提供对应的分析数据，在满足及时性的同时也提升了用户体验。
第二方面，本发明提供了一种数据采集和分析方法，应用于数据源网元，包括：响应于通信网络数据分析网元发送的目标数据订阅指示，向所述通信网络数据分析网元发送订阅成功指示；在满足订阅条件的情况下，向所述通信网络数据分析网元发送目标数据。
本公开提供一种数据采集和分析方法，数据源网元为通信网络数据分析网元提供目标数据，便于通信网络数据分析网元后续及时提供分析结果。为改善实时性提供实现通道。
第三方面，本发明提供了一种数据采集和分析方法，应用于网络存储库网元，包括：接收通信网络数据分析网元发送的网络网元服务注册请求；存储所述通信网络数据分析网元的网络网元信息；其中，所述网络网元信息包括支持的网络网元信息；向所述通信网络数据分析网元发送所述网络网元服务注册成功消息；接收到网络功能网元发送的网络功能网元服务发现指示；根据所述服务发现指示确定出对应的所述通信网络数据分析网元；向所述通信网络数据分析网元发送网络功能网元服务发现响应指示，其中，所述响应指示包括所述通信网络数据分析网元的属性信息。
本公开提供一种数据采集和分析方法，网络存储库网元作为通信网络数据分析网元的存储中心。同时，也便于根据nwdaf服务消费者的特征信息查到到对应的通信网络数据分析网元。从而提高工作效率，进一步加快后续的获取数据分析结果的进程。
第四方面，本发明提供了一种数据采集和分析方法，应用于网络功能网元，包括：向网络存储库网元发送网络功能网元服务发现指示，其中，所述服务发现指示用于指示实时获取目标数据的分析结果；接收到所述网络存储库网元发送的网络功能网元服务发现响应指示；根据所述网络功能网元服务发现响应指示，与所述通信网络数据分析网元进行通信。
本公开提供一种数据采集和分析方法，网络功能网元发出数据分析请求，通过网络存储库网元的调配，查找到对应的通信网络数据分析网元，从而及时实现分析结果的交互。
第五方面，本发明提供了一种数据采集和分析装置，应用于通信网络数据分析网元，包括：处理模块，用于注册网络功能网元服务；发送模块，用于向数据源网元发送目标数据订阅指示；其中，所述目标数据订阅指示用于指示所述数据源网元在检测到目标数据满足目标订阅条件时，将所述目标数据发送给所述通信网络数据分析网元；接收模块，用于接收到所述数据源网元发送的目标数据；处理模块，用于根据所述目标数据进行分析，得到分析结果。
第六方面，本发明提供了一种数据采集和分析装置，应用于数据源网元，包括：发送模块，用于响应于通信网络数据分析网元发送的目标数据订阅指示，向所述通信网络数据分析网元发送订阅成功指示；发送模块，还用于在满足订阅条件的情况下，向所述通信网络数据分析网元发送目标数据。
第七方面，本发明提供了一种数据采集和分析装置，应用于网络存储库网元，包括：接收单元，用于接收通信网络数据分析网元发送的网络网元服务注册请求；存储模块，用于存储所述通信网络数据分析网元的网络网元信息；其中，所述网络网元信息包括支持的nf网元信息；发送模块，用于向所述通信网络数据分析网元发送所述网络网元服务注册成功消息；接收模块，还用于接收到网络功能网元发送的网络功能网元服务发现指示；处理模块，用于根据所述服务发现指示确定出对应的所述通信网络数据分析网元；发送模块，还用于发送网络功能网元服务发现响应指示，其中，所述响应指示包括所述通信网络数据分析网元的属性信息。
第八方面，本发明提供了一种数据采集和分析装置，应用于网络功能网元，包括：发送模块，用于向网络存储库网元发送网络功能网元服务发现指示，其中，所述服务发现指示用于指示实时获取目标数据的分析结果；接收模块，用于接收到所述网络存储库网元发送的网络功能网元服务发现响应指示；通信模块，用于根据所述网络功能网元服务发现响应指示，与所述通信网络数据分析网元进行通信。
第九方面，本公开提供了一种计算机可读的存储介质，存储介质中存储有计算机程序，其中，计算机程序被设置为运行时执行上述任一项方法实施例中的步骤。
第十方面，本公开提供了一种电子装置，包括存储器和处理器，其特征在于，存储器中存储有计算机程序，处理器被设置为运行计算机程序以执行上述任一项方法实施例中的步骤。
本公开中第五方面、第九方面和第十方面及其各种实现方式的具体描述，可以参考第一方面中的详细描述；并且，第五方面、第九方面和第十方面及其各种实现方式的有益效果，可以参考第一方面实现方式中的有益效果分析。
本公开中第六方面、第九方面和第十方面及其各种实现方式的具体描述，可以参考第二方面中的详细描述；第六方面、第九方面和第十方面及其各种实现方式的有益效果，可以参考第三方面实现方式中的有益效果分析，此处不再赘述。
本公开中第七方面、第九方面和第十方面及其各种实现方式的具体描述，可以参考第三方面中的详细描述；并且，第七方面、第九方面和第十方面及其各种实现方式的有益效果，可以参考第一方面实现方式中的有益效果分析。
本公开中第八方面至第十方面及其各种实现方式的具体描述，可以参考第三方面中的详细描述；第八方面至第十方面及其各种实现方式的有益效果，可以参考第三方面实现方式中的有益效果分析，此处不再赘述。
本公开的这些方面或其他方面在以下的描述中会更加简明易懂。
附图说明
为了更清楚地说明本发明实施例中的技术方案，下面将对实施例描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。
图1为本发明实施例提供的一种实施环境的示意图；
图2为本发明实施例提供的一种数据采集和分析方法的流程图；
图3为本发明实施例提供的一种数据采集和分析方法的流程图；
图4为本发明实施例提供的一种数据采集和分析方法的流程图；
图5为本发明实施例提供的一种数据采集和分析方法的流程图；
图6为本发明实施例提供的一种数据采集和分析方法的流程图；
图7为本发明实施例提供的一种数据采集和分析装置的结构示意图；
图8为本发明实施例提供的一种数据采集和分析装置的结构示意图；
图9为本发明实施例提供的一种数据采集和分析装置的结构示意图；
图10为本发明实施例提供的一种数据采集和分析装置的结构示意图；
图11为本发明实施例提供的一种可选的电子装置结构示意图。
具体实施方式
下面将结合本发明实施例中的附图，对本发明实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是本发明一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。
术语“第一”、“第二”仅用于描述目的，而不能理解为指示或暗示相对重要性或者隐含指明所指示的技术特征的数量。由此，限定有“第一”、“第二”的特征可以明示或者隐含地包括一个或者更多个该特征。在本发明的描述中，除非另有说明，“多个”的含义是两个或两个以上。
在对本公开提供的数据采集和分析方法进行详细介绍之前，先对本公开涉及的应用场景和实施环境进行简单介绍。
首先，对本公开涉及的应用场景进行简单介绍。
目前，国际通信标准组织第三代合作伙伴计划(3rdgenerationpartnershipproject，3gpp)在第五代移动通信技术(5th-generation，5g)核心网(5gcore，5gc)的框架内定义了基于网络数据分析网元(networkdataanalyticsfunction，nwdaf)的5g原生的大数据分析及ai技术应用框架，nwdaf网元支持通过标准化的通信网络流程进行对应的数据采集、数据分析及分析结果反馈等机制，进一步提升了5g网络的自动化管理、运营和优化能力。
nwdaf网元能够从5gc的控制面网络网元(networkfunction，nf)获取网络资源使用情况或nf负载等数据信息。
当前标准定义的数据采集和分析框架中，数据分析流程包含以下几个主要步骤：
(1)其他nf网元或网络功能实体(即nwdaf服务消费者)向nwdaf网元请求特定分析类型的数据分析结果。
(2)nwdaf网元向对应该分析类型所需的数据源网元请求获取相关的数据。
(3)nwdaf网元根据从数据源网元处获取的数据进行数据分析，生成针对nwdaf服务消费者所请求的分析类型的分析结果。
(4)nwdaf网元将数据分析结果返回给nwdaf服务消费者。
其中，步骤2和步骤3对应的数据采集和数据分析动作只有当nwdaf网元收到nwdaf服务消费者的数据分析请求时才会触发，而受制于当前网络状态以及nwdaf内部的数据分析算法和模型，数据采集和数据分析所消耗的时间相对来说是不可控的。
在这种情况下，如果nwdaf服务消费者所请求的分析类型需要较高的实时性，在完整的执行了整个流程以后，其反馈结果可能已不具备实时性。
为了解决现有技术的问题，本公开提供的一种数据采集和分析方法。该方法可以在nwdaf服务消费者发出数据分析请求之前，提前进行数据采集和数据分析；当nwdaf服务消费者发出触发请求时，可及时回复分析结果，避免因计算时间过久，而丧失数据的实时性。
如图1所示，其示出了本公开涉及的实施环境(实施架构)的示意图。该实施环境中可以包括：通信网络数据分析网元(real-timecommunicationcapablenetworkdataanalyticsfunction，rt-nwdaf)110、数据源网元120、网络存储库网元(networkrepositoryfunction，nrf)130和nf网元140。其中，rt-nwdaf网元110、数据源网元120、nrf网元130和nf网元140通过有线通讯方式或无线通讯方式进行通信。
其中，rt-nwdaf网元110支持通过标准化通信网络流程进行实时数据采集、数据分析及分析结果反馈等机制。
其中，数据源网元120包括但不限于下列各种网络功能类型：运营商oam、应用功能af、其他nf网元140和nrf网元130等。
其中，nrf网元130支持业务发现功能，接收网元发过来的发现请求，提供发现的网元信息给请求方；维护可用网元实例的特征和其支持的业务能力。
其中，nf网元140具体可以为5g核心网控制面功能实体中任一实例化的功能实体，例如接入和移动性管理功能(accessandmobilitymanagementfunction，amf)装置(图1中未示出)、会话管理功能(sessionmanagementfunction，smf)装置(图1中未示出)、策略控制功能(policycontrolfunction，pcf)装置(图1中未示出)等。
如图2所示，本实施例公开一种数据采集和分析方法，应用于通信网络数据分析网元，包括步骤201-步骤204。
201、注册网络功能网元服务。
本步骤中，为支持网络数据分析网元(networkdataanalyticsfunction，nwdaf)的实时交互的功能，定义一个专门用于针对特定的分析类型提供实时通信的nwdaf网元，即通信网络数据分析网元(real-timecommunicationcapablenwdaf，rt-nwdaf)。rt-nwdaf网元只负责处理需要基于实时通信方式实现的分析类型。
rt-nwdaf网元需要实现对应功能时，需要先在网络存储库网元(networkrepositoryfunction，nrf)进行注册，注册后才可用于实时网络数据分析。
其中，如图2所示，步骤201包括如下子步骤2011-步骤2012。
进一步地，步骤201包括：
2011、向网络存储库网元发送网络功能服务注册请求；其中，注册请求中包括实时通信能力信息和支持的网络功能网元。
本步骤中，rt-nwdaf网元被配置、编排成为可使用的功能实体。配置完成后，rt-nwdaf网元向nrf网元发送网络功能网元(networkfunction，nf)服务注册请求，请求消息中携带rt-nwdaf网元支持实时通信能力信息和rt-nwdaf网元支持的nf网元。
具体的，rt-nwdaf收到来自nf网元的数据分析请求时可以实时反馈数据分析结果。其中，数据分析包括nf负载分析、网络性能分析和异常行为分析等。
2012、接收到网络功能服务注册响应消息，完成注册。
本步骤中，nrf网元向rt-nwdaf网元返回nf服务注册响应消息，通知rt-nwdaf注册成功。
202、向数据源网元发送目标数据订阅指示；其中，目标数据订阅指示用于指示数据源网元在检测到目标数据满足目标订阅条件时，将目标数据发送给通信网络数据分析网元。
本步骤中，当rt-nwdaf网元在nrf网元中的完成nf服务注册后；rt-nwdaf网元向数据源网元发送目标数据订阅指示，指示获取所支持的nf网元的目标数据。
目标数据订阅指示用于指示数据源网元在检测到目标数据满足目标订阅条件时，将目标数据发送给通信网络数据分析网元。
其中，目标订阅条件是指数据源网元在rt-nwdaf网元未向数据源网元退订数据/事件的情况下，持续的向rt-nwdaf网元上报rt-nwdaf网元所订阅的数据或事件。
其中，数据源网元可以是其他nf网元、应用功能网元(applicationfunction，af)、nrf网元或网管管理网关(operationadministrationandmaintenance，oam)等。
203、接收到数据源网元发送的目标数据。
本步骤中，数据源网元向rt-nwdaf网元回复目标数据订阅成功。基于rt-nwdaf网元发送的目标数据订阅指示，当满足订阅条件时，数据源网元向rt-nwdaf网元上报对应的数据/事件信息。
具体的，若rt-nwdaf网元向数据源网元订阅的是ue位置信息，因此当ue位置改变时，数据源网元都应该向rt-nwdaf网元上报ue位置改变事件，并上报ue的最新位置。
204、根据目标数据进行分析，得到分析结果。
本步骤中，当rt-nwdaf网元获取到数据源网元发送的目标数据后，根据特定的数据分析模型对目标数据进行分析，并持续更新分析结果。
进一步地，还包括：
向数据源网元发送目标数据退订指示；其中，目标数据退订指示用于指示数据源网元停止目标数据的上报。
本步骤中，当rt-nwdaf网元决定不再需要目标数据后，rt-nwdaf网元将向数据源网元发送目标数据退订指示，指示该数据源网元停止向rt-nwdaf网元上报目标数据。
示例性地，rt-nwdaf网元在nrf网元进行注册，注册成功后，通过数据源网元获取目标数据进行分析。rt-nwdaf网元通过注册在nrf网元存储基础信息，便于后续根据nwdaf服务消费者需求快速查找到对应的rt-nwdaf网元。注册成功后，及时获取数据并进行分析，输出分析结果。便于当系统接收到nwdaf服务消费者的请求后，迅速响应，立即提供对应的分析数据，在满足及时性的同时也提升了用户体验。
如图3所示，一种数据采集和分析方法，应用于数据源网元，该方法包括步骤301-步骤303。
301、响应于通信网络数据分析网元发送的目标数据订阅指示，向通信网络数据分析网元发送订阅成功指示。
本步骤中，当数据源网元接收到rt-nwdaf网元发送的目标数据订阅指示时，回复rt-nwdaf网元目标数据订阅成功。
302、在满足订阅条件的情况下，向通信网络数据分析网元发送目标数据。
本步骤中，如步骤102，当满足订阅条件时，数据源网元向rt-nwdaf网元上报对应的数据/事件信息。
进一步地，还包括
303、响应于通信网络数据分析网元发送的目标数据退订指示，停止目标数据上报。
本步骤中，如上，当rt-nwdaf网元决定不再需要目标数据后，rt-nwdaf网元将向数据源网元发送目标数据退订指示，指示该数据源网元停止向rt-nwdaf网元上报目标数据。同时，数据源网元在本地删除和该rt-nwdaf网元的关联信息。
示例性地，数据源网元为rt-nwdaf网元提供目标数据，便于rt-nwdaf网元后续及时提供分析结果。为改善实时性提供实现通道。
如图4所示，一种数据采集和分析方法，应用于网络存储库网元，该方法包括步骤401-步骤406。
401、接收通信网络数据分析网元发送的网络网元服务注册请求。
本步骤中，为实现针对特定nf网元的实时网络数据分析处理，现定义rt-nwdaf网元。
为实现该功能，需rt-nwdaf网元向nrf网元发起nf服务注册流程。
402、存储通信网络数据分析网元的网络网元信息；其中，网络网元信息包括支持的nf网元信息。
本步骤中，当nrf网元接收到来自rt-nwdaf发送的nf服务注册请求时，nrf网元存储rt-nwdaf网元携带的支持的nf网元信息。
403、向通信网络数据分析网元发送网络网元服务注册成功消息。
本步骤中，nrf网元存储该rt-nwdaf网元包含的nf网元信息后，向rt-nwdaf网元回复注册成功消息。便于开展后续的数据分析工作。
404、接收到网络功能网元发送的网络功能网元服务发现指示。
本步骤中，nf网元作为nwdaf网元的服务消费者，向nrf网元发送nf服务发现指示。该nf服务发现指示中携带希望获得该nf网元对应的实时数据分析。
具体的，nf网元对应的实时数据分析如:nf网元的负载信息等等。
405、根据服务发现指示确定出对应的通信网络数据分析网元。
本步骤中，由于服务发现指示中携带nf信息。根据服务发现信息内的nf信息通过nrf网元确定出对应的rt-nwdaf网元。
406、向网络功能网元发送网络功能网元服务发现响应指示，其中，响应指示包括通信网络数据分析网元的属性信息。
本步骤中，nrf网元向nf网元回复服务发现响应指示，该服务发现响应指示中携带确定出的rt-nwdaf网元信息。具体的，包括ip地址、域名等。
示例性地，nrf网元作为rt-nwdaf网元的存储中心。同时，也便于根据nwdaf服务消费者的特征信息查到到对应的rt-nwdaf网元。从而提高工作效率，进一步加快后续的获取数据分析结果的进程。
如图5所示，一种数据采集和分析方法，应用于网络功能网元，该方法可以包括步骤501-步骤503。
501、向网络存储库网元发送网络功能网元服务发现指示，其中，服务发现指示用于指示实时获取目标数据的分析结果。
本步骤中，nwdaf服务消费者为nf网元或网络功能实体向nrf网元发送nf服务发现请求，请求消息中携带希望获得该nf网元的数据分析指示。
502、接收到网络存储库网元发送的网络功能网元服务发现响应指示。
本步骤中，nrf网元查找到对应的rt-nwdaf网元将rt-nwdaf网元的信息以响应指示的方式回复至nf网元。
503、根据网络功能网元服务发现响应指示，与通信网络数据分析网元进行通信。
本步骤中，根据网络功能网元服务发现响应指示中包含的rt-nwdaf网元的信息，根据rt-nwdaf网元的信息，实现nf网元和rt-nwdaf网元的通信以及后续的数据交换。
示例性地，nwdaf服务消费者发出数据分析请求，通过nrf网元的调配，查找到对应的rt-nwdaf网元，从而及时实现分析结果的交互。
图6是根据一示例性实施例示出的一种数据传输方法的流程图，该方法可以包括步骤601-步骤617。
601、通信网络数据分析网元配置形成功能实体。
602、向网络存储库网元发送网络功能服务注册请求；其中，注册请求中包括实时通信能力信息和支持的网络功能网元。
603、接收通信网络数据分析网元发送的网络网元服务注册请求。
604、存储通信网络数据分析网元的网络网元信息；其中，网络网元信息包括支持的nf网元信息。
605、向通信网络数据分析网元发送网络网元服务注册成功消息。
606、接收到网络功能服务注册响应消息，完成注册。
607、向数据源网元发送目标数据订阅指示；其中，目标数据订阅指示用于指示数据源网元在检测到目标数据满足目标订阅条件时，将目标数据发送给通信网络数据分析网元。
608、响应于通信网络数据分析网元发送的目标数据订阅指示，向通信网络数据分析网元发送订阅成功指示。
609、在满足订阅条件的情况下，向通信网络数据分析网元发送目标数据。
610、接收到数据源网元发送的目标数据。
611、根据目标数据进行分析，得到分析结果。
612、向网络存储库网元发送网络功能网元服务发现指示，其中，服务发现指示用于指示实时获取目标数据的分析结果。
613、接收到网络功能网元发送的网络功能网元服务发现指示。
614、根据服务发现指示确定出对应的通信网络数据分析网元。
615、向网络功能网元发送网络功能网元服务发现响应指示，其中，响应指示包括通信网络数据分析网元的属性信息。
616、接收到网络存储库网元发送的网络功能网元服务发现响应指示。
617、根据网络功能网元服务发现响应指示，与通信网络数据分析网元进行通信。
上述实施例提供的技术方案至少带来以下有益效果：由于本申请的智能仪表获取到了配电设备的基础数据，根据基础数据从而生成电气连接图。同时智能仪表实时监测配电设备的运行数据，根据运行数据与基础数据进行分析计算；输出分析结果并进行显示和报警处理。本申请在常规电量智能仪表的基础上，将配电设备的相关数据信息都录入到智能仪表，智能仪表将基础数据和实际的运行数据进行比较、分析；并将分析结果显示出来，若存在异常情况，则进行报警处理，从而提高配电系统运行的可靠性。
上述主要从方法的角度对本公开实施例提供的方案进行了介绍。为了实现上述功能，其包含了执行各个功能相应的硬件结构和/或软件模块。本领域技术人员应该很容易意识到，结合本文中所公开的实施例描述的各示例的单元及算法步骤，本公开能够以硬件或硬件和计算机软件的结合形式来实现。某个功能究竟以硬件还是计算机软件驱动硬件的方式来执行，取决于技术方案的特定应用和设计约束条件。专业技术人员可以对每个特定的应用来使用不同方法来实现所描述的功能，但是这种实现不应认为超出本公开的范围。
图7是根据一示例性实施例示出的一种数据采集和分析装置的结构示意图，应用于通信网络数据分析网元，该数据采集和分析装置可以用于执行图2所示的数据传输方法。作为一种可实现方式，该装置可以包括处理模块710、发送模块720和接收模块730。
处理模块710，用于注册网络功能网元服务；例如，结合图2，处理模块710可以用于执行步骤201。
发送模块720，用于向数据源网元发送目标数据订阅指示；其中，目标数据订阅指示用于指示数据源网元在检测到目标数据满足目标订阅条件时，将目标数据发送给通信网络数据分析网元；例如，结合图2，发送模块720可以用于执行步骤202。
接收模块730，用于接收到数据源网元发送的目标数据；例如，结合图2，接收模块730可以用于执行步骤203。
处理模块710，用于根据目标数据进行分析，得到分析结果。例如，结合图2，处理模块710可以用于执行步骤204。
进一步地，处理模块710包括：
第一发送单元7101，用于向网络存储库网元发送网络功能服务注册请求；其中，注册请求中包括实时通信能力信息和支持的网络功能网元；例如，结合图2，第一发送单元7101可以用于执行步骤2011。
第一接收单元7102，用于接收到网络功能服务注册响应消息，完成注册。例如，结合图2，第一接收单元7102可以用于执行步骤2012。
进一步地，发送模块720，还用于向数据源网元发送目标数据退订指示；其中，目标数据退订指示用于指示数据源网元停止目标数据的上报。
图8是根据一示例性实施例示出的一种数据采集和分析装置的结构示意图，应用于通信网络数据分析网元，该数据采集和分析装置可以用于执行图3所示的数据传输方法。作为一种可实现方式，该装置可以包括发送模块810和处理模块820。
发送模块810，用于响应于通信网络数据分析网元发送的目标数据订阅指示，向通信网络数据分析网元发送订阅成功指示；例如，结合图3，发送模块810可以用于执行步骤301。
发送模块810，还用于在满足订阅条件的情况下，向通信网络数据分析网元发送目标数据。例如，结合图3，发送模块810还可以用于执行步骤302。
进一步地，还包括：
处理模块820，用于响应于通信网络数据分析网元发送的目标数据退订指示，停止目标数据上报。例如，结合图3，处理模块820可以用于执行步骤303。
图9是根据一示例性实施例示出的一种数据采集和分析装置的结构示意图，应用于通信网络数据分析网元，该数据采集和分析装置可以用于执行图4所示的数据传输方法。作为一种可实现方式，该装置可以包括接收模块910、存储模块920、发送模块930和处理模块940。
接收模块910，用于接收通信网络数据分析网元发送的网络网元服务注册请求；例如，结合图4，接收模块910可以用于执行步骤401。
存储模块920，用于存储通信网络数据分析网元的网络网元信息；其中，网络网元信息包括支持的nf网元信息；例如，结合图4，存储模块920可以用于执行步骤402。
发送模块930，用于向通信网络数据分析网元发送网络网元服务注册成功消息；例如，结合图4，发送模块930可以用于执行步骤403。
接收模块910，还用于接收到网络功能网元发送的网络功能网元服务发现指示；例如，结合图4，接收模块910可以用于执行步骤404。
处理模块940，用于根据服务发现指示确定出对应的通信网络数据分析网元；例如，结合图4，处理模块940可以用于执行步骤405。
发送模块930，还用于向网络功能网元发送网络功能网元服务发现响应指示，其中，响应指示包括通信网络数据分析网元的属性信息。例如，结合图4，发送模块930可以用于执行步骤406。
图10是根据一示例性实施例示出的一种数据采集和分析装置的结构示意图，应用于通信网络数据分析网元，该数据采集和分析装置可以用于执行图5所示的数据传输方法。作为一种可实现方式，该装置可以包括发送模块1010、接收模块1020和通信模块1030。
发送模块1010，用于向网络存储库网元发送网络功能网元服务发现指示，其中，服务发现指示用于指示实时获取目标数据的分析结果；例如，结合图5，发送模块1010可以用于执行步骤501。
接收模块1020，用于接收到网络存储库网元发送的网络功能网元服务发现响应指示；例如，结合图5，接收模块1020可以用于执行步骤502。
通信模块1030，用于根据网络功能网元服务发现响应指示，与通信网络数据分析网元进行通信。例如，结合图5，通信模块1030可以用于执行步骤503。
当然，本公开实施例提供的数据采集和分析装置包括但不限于上述模块，例如还可以包括存储模块。存储模块可以用于存储该数据采集和分析装置的程序代码，还可以用于存储数据采集和分析装置在运行过程中生成、接收到的数据等。
根据本公开实施例的又一个方面，还提供了一种用于实施上述数据采集和分析方法的电子设备，上述电子设备可以但不限于应用于服务器中。如图11所示，该电子设备包括存储器1110和处理器1120，该存储器1110中存储有计算机程序，该处理器1120被设置为通过计算机程序执行上述任一项方法实施例中的步骤。
进一步地，在本实施例中，上述电子设备可以位于计算机网络的多个网络设备中的至少一个网络设备。
进一步地，在本实施例中，上述处理器1120可以被设置为通过计算机程序执行如图6的步骤。
可选地，本领域普通技术人员可以理解，图11所示的结构仅为示意，电子设备也可以是智能手机(如android手机、ios手机等)、平板电脑、掌上电脑以及移动互联网设备(mobileinternetdevices，mid)、pad等终端设备。图11其并不对上述电子设备的结构造成限定。例如，电子设备还可包括比图11中所示更多或者更少的组件(如网络接口等)，或者具有与图11所示不同的配置。
其中，存储器1110可用于存储软件程序以及模块，如本公开实施例中的数据采集和分析方法和装置对应的程序指令/模块，处理器1120通过运行存储在存储器1110内的软件程序以及模块，从而执行各种功能应用以及数据处理，即实现上述的数据采集和分析方法。存储器1110可包括高速随机存储器，还可以包括非易失性存储器，如一个或者多个磁性存储装置、闪存、或者其他非易失性固态存储器。在一些实例中，存储器1110可进一步包括相对于处理器1120远程设置的存储器，这些远程存储器可以通过网络连接至终端。上述网络的实例包括但不限于互联网、企业内部网、局域网、移动通信网及其组合。其中，存储器1110具体可以但不限于用于储存数据采集和分析方法的程序步骤。此外，还可以包括但不限于上述数据采集和分析装置中的其他模块单元，本示例中不再赘述。
可选地，上述的传输装置1130用于经由一个网络接收或者发送数据。上述的网络具体实例可包括有线网络及无线网络。在一个实例中，传输装置1130包括一个网络适配器(networkinterfacecontroller，nic)，其可通过网线与其他网络设备与路由器相连从而可与互联网或局域网进行通讯。在一个实例中，传输装置1130为射频(radiofrequency，rf)模块，其用于通过无线方式与互联网进行通讯。
此外，上述电子设备还包括：显示器1140，用于显示可疑帐号的告警推送；和连接总线1150，用于连接上述电子设备中的各个模块部件。
可选地，本公开另一实施例还提供一种计算机可读存储介质，该计算机可读存储介质中存储有指令，当指令在计算机上运行时，使得计算机执行上述方法实施例所示的方法流程中数据采集和分析装置执行的各个步骤。
可选地，在本公开另一实施例中，还提供一种计算机程序产品，该计算机程序产品包括指令，当指令在计算机上运行时，使得计算机执行上述方法实施例所示的方法流程中数据采集和分析装置执行的各个步骤。
可选地，在本实施例中，本领域普通技术人员可以理解上述实施例的各种方法中的全部或部分步骤是可以通过程序来指令终端设备相关的硬件来完成，该程序可以存储于一计算机可读存储介质中，存储介质可以包括：闪存盘、只读存储器(read-onlymemory，rom)、随机存取器(randomaccessmemory，ram)、磁盘或光盘等。
上述本公开实施例序号仅仅为了描述，不代表实施例的优劣。
上述实施例中的集成的单元如果以软件功能单元的形式实现并作为独立的产品销售或使用时，可以存储在上述计算机可读取的存储介质中。基于这样的理解，本公开的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的全部或部分可以以软件产品的形式体现出来，该计算机软件产品存储在存储介质中，包括若干指令用以使得一台或多台计算机设备(可为个人计算机、服务器或者网络设备等)执行本公开各个实施例方法的全部或部分步骤。
在本公开的上述实施例中，对各个实施例的描述都各有侧重，某个实施例中没有详述的部分，可以参见其他实施例的相关描述。
在本公开所提供的几个实施例中，应该理解到，所揭露的客户端，可通过其它的方式实现。其中，以上所描述的装置实施例仅仅是示意性的，例如单元的划分，仅仅为一种逻辑功能划分，实际实现时可以有另外的划分方式，例如多个单元或组件可以结合或者可以集成到另一个系统，或一些特征可以忽略，或不执行。另一点，所显示或讨论的相互之间的耦合或直接耦合或通信连接可以是通过一些接口，单元或模块的间接耦合或通信连接，可以是电性或其它的形式。
作为分离部件说明的单元可以是或者也可以不是物理上分开的，作为单元显示的部件可以是或者也可以不是物理单元，即可以位于一个地方，或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部单元来实现本实施例方案的目的。
另外，在本公开各个实施例中的各功能单元可以集成在一个处理单元中，也可以是各个单元单独物理存在，也可以两个或两个以上单元集成在一个单元中。上述集成的单元既可以采用硬件的形式实现，也可以采用软件功能单元的形式实现。
以上仅是本公开的优选实施方式，应当指出，对于本技术领域的普通技术人员来说，在不脱离本公开原理的前提下，还可以做出若干改进和润饰，这些改进和润饰也应视为本公开的保护范围。
1.一种数据采集和分析方法，应用于通信网络数据分析网元，其特征在于，包括：
确定网络功能网元服务已注册成功；
向数据源网元发送目标数据订阅指示；其中，所述目标数据订阅指示用于指示所述数据源网元在检测到目标数据满足目标订阅条件时，将所述目标数据发送给所述通信网络数据分析网元；
接收到所述数据源网元发送的目标数据；
根据所述目标数据进行分析，得到分析结果。
2.如权利要求1所述的分析方法，其特征在于，所述注册网络功能网元服务包括：
向网络存储库网元发送所述网络功能服务注册请求；其中，所述注册请求中包括实时通信能力信息和支持的网络功能网元；
接收到所述网络功能服务注册响应消息，完成注册。
3.如权利要求1所述的分析方法，其特征在于，所述根据所述目标数据进行分析，得到分析结果之后，还包括：
向数据源网元发送目标数据退订指示；其中，所述目标数据退订指示用于指示所述数据源网元停止所述目标数据的上报。
4.一种数据采集和分析方法，应用于数据源网元，其特征在于，包括：
响应于通信网络数据分析网元发送的目标数据订阅指示，向所述通信网络数据分析网元发送订阅成功指示；
在满足订阅条件的情况下，向所述通信网络数据分析网元发送目标数据。
5.如权利要求4所述的分析方法，其特征在于，在所述在满足订阅条件的情况下，向所述通信网络数据分析网元发送目标数据步骤之后，还包括：
响应于所述通信网络数据分析网元发送的目标数据退订指示，停止所述目标数据上报。
6.一种数据采集和分析方法，应用于网络存储库网元，其特征在于，包括：
接收通信网络数据分析网元发送的网络网元服务注册请求；
存储所述通信网络数据分析网元的网络网元信息；其中，所述网络网元信息包括支持的网络网元信息；
向所述通信网络数据分析网元发送所述网络网元服务注册成功消息；
接收到网络功能网元发送的网络功能网元服务发现指示；
根据所述服务发现指示确定出对应的所述通信网络数据分析网元；
向所述网络功能网元发送网络功能网元服务发现响应指示，其中，所述响应指示包括所述通信网络数据分析网元的属性信息。
7.一种数据采集和分析方法，应用于网络功能网元，其特征在于，包括：
向网络存储库网元发送网络功能网元服务发现指示，其中，所述服务发现指示用于指示实时获取目标数据的分析结果；
接收到所述网络存储库网元发送的网络功能网元服务发现响应指示；
根据所述网络功能网元服务发现响应指示，与通信网络数据分析网元进行通信。
8.一种数据采集和分析装置，应用于通信网络数据分析网元，其特征在于，包括：
处理模块，用于注册网络功能网元服务；
发送模块，用于向数据源网元发送目标数据订阅指示；其中，所述目标数据订阅指示用于指示所述数据源网元在检测到目标数据满足目标订阅条件时，将所述目标数据发送给所述通信网络数据分析网元；
接收模块，用于接收到所述数据源网元发送的目标数据；
处理模块，用于根据所述目标数据进行分析，得到分析结果。
9.如权利要求8所述的分析装置，其特征在于，所述处理模块包括：
发送单元，用于向网络存储库网元发送所述网络功能服务注册请求；其中，所述注册请求中包括实时通信能力信息和支持的网络功能网元；
接收单元，用于接收到所述网络功能服务注册响应消息，完成注册。
10.如权利要求8所述的分析装置，其特征在于，包括：
发送模块，还用于向数据源网元发送目标数据退订指示；其中，所述目标数据退订指示用于指示所述数据源网元停止所述目标数据的上报。
11.一种数据采集和分析装置，应用于数据源网元，其特征在于，包括：
发送模块，用于响应于通信网络数据分析网元发送的目标数据订阅指示，向所述通信网络数据分析网元发送订阅成功指示；
发送模块，还用于在满足订阅条件的情况下，向所述通信网络数据分析网元发送目标数据。
12.如权利要求11所述的分析装置，其特征在于，还包括：
处理模块，用于响应于所述通信网络数据分析网元发送的目标数据退订指示，停止所述目标数据上报。
13.一种数据采集和分析装置，应用于网络存储库网元，其特征在于，包括：
接收单元，用于接收通信网络数据分析网元发送的网络网元服务注册请求；
存储模块，用于存储所述通信网络数据分析网元的网络网元信息；其中，所述网络网元信息包括支持的网络网元信息；
发送模块，用于向所述通信网络数据分析网元发送所述网络网元服务注册成功消息；
接收模块，还用于接收到网络功能网元发送的网络功能网元服务发现指示；
处理模块，用于根据所述服务发现指示确定出对应的所述通信网络数据分析网元；
发送模块，还用于向所述网络功能网元发送网络功能网元服务发现响应指示，其中，所述响应指示包括所述通信网络数据分析网元的属性信息。
14.一种数据采集和分析装置，应用于网络功能网元，其特征在于，包括：
发送模块，用于向网络存储库网元发送网络功能网元服务发现指示，其中，所述服务发现指示用于指示实时获取目标数据的分析结果；
接收模块，用于接收到所述网络存储库网元发送的网络功能网元服务发现响应指示；
通信模块，用于根据所述网络功能网元服务发现响应指示，与通信网络数据分析网元进行通信。
15.一种计算机可读的存储介质，其特征在于，所述存储介质中存储有计算机程序，其中，所述计算机程序被设置为运行时执行所述权利要求1至7任一项中所述的方法。
16.一种电子设备，包括存储器和处理器，其特征在于，所述存储器中存储有计算机程序，所述处理器被设置为运行所述计算机程序以执行所述权利要求1至7任一项中所述的方法。
技术总结