CN114328502B 一种数据收集方法、装置、网络设备和存储介质 （中国移动通信有限公司研究院）

络数据分析功能(NWDAF)接收消费者发送的第一消息，所述第一消息用于请求或订阅NWDAF分析所述第一NWDAF通过第一网络设备查询是否已有NWDAF正在收集或已存储与所述第一参数匹配的2第一网络数据分析功能NWDAF接收消费者发送的第一消息，所述第一消息用于请求或订阅NWDAF分析服务；所述第一消息中包括第一参数；所述第一参数至少包括以下至少之在收集数据开始前，第一NWDAF通过第一网络设备查询是否已有NW所述第一NWDAF通过所述第一网络设备未发现已有NWDAF正在收集或已存储与所述第所述第一NWDAF接收所述数据提供者发送的对应于所述第二消息的所述第一NWDAF接收所述数据提供者发送的与所述第一参数匹配所述第一NWDAF通过所述第一网络设备发现正在收集与所述第一参数匹配的数据的第所述第一NWDAF接收所述第二NWDAF发送的对应于所述第三消息的所述第一NWDAF接收所述第二NWDAF发送的与所述第一参数匹配所述第一NWDAF通过所述第一网络设备发现已有NWDAF和第二网络设备已存储与所述述NWDAF或所述第二网络设备；所述目标NWDAF基于所述NWDAF和所述第二网络设备的负载所述第一NWDAF向所述目标NWDAF发送第四消息，所述第四消息用所述第一NWDAF接收所述目标NWDAF发送的对应于所述第四消息的所述第一NWDAF判断所述目标NWDAF已存储的数据是否满足所在所述目标NWDAF已存储的数据满足所述第一参数的情况下，所在所述目标NWDAF已存储的数据不满足所述第一参数的情所述第一NWDAF向所述数据提供者发送第五消息；所述第五消息用于请求或订阅满足所述第一NWDAF接收所述数据提供者发送的对应于所述第五消息的3所述第一NWDAF接收所述数据提供者发送的所述第6.根据权利要求1至5任一项所述的方法，其特所述第一NWDAF向所述第一网络设备发送第六消息；所述第六消息用于注册或更新数所述第一NWDAF向所述第一网络设备发送用于注册或更新分析结果的第八消息；所述所述第一NWDAF通过网络存储功能NRF发现第二所述第一NWDAF向所述第二网络设备发送用于请求数据汇聚的第九消息，接收所述第所述第一NWDAF向所述第二网络设备发送所述数据分第二网络设备接收第一网络数据分析功能NWDAF发送的用于请求数据汇聚的第九消所述第二网络设备基于所述数据的相关信息判断是否存在匹配的数据正在传输或已存储，和/或，基于所述分析报告信息判断是否存在匹配的数据分析结果正在传输或已存在确定存在匹配的数据正在传输或已存储，和，存在匹配的数据已存储的情况下，所述第二网络设备向第一NWDAF发送对应于所述第九消息的拒绝响应消传输或已存储的情况下，所述第二网络设备向所述第一NWDAF发送对应于所述第九消息的所述第二网络设备在开始汇聚数据和/或数据分析结果时，向第一网络设备发送第十所述第二网络设备在完成汇聚数据和/或数据分析结果时，向所述第一网络设备发送4正在收集数据的第二网络数据分析功能NWDAF接收第一NWDA在确定正在收集的数据不满足所述第一参数的情况下，向数据提供者发送第十二消所述第二NWDAF向第一网络设备发送第十三消息，所述第十三消息用于更新数据的配第一网络设备接收网络数据分析功能NWDAF发送的第十四消息，所述第十四消息用于所述第一网络设备基于所述数据获取状态确定所述NWDAF的数据收集状态基于第一NWDAF的查询，向所述第一NWDAF发送包含是否已有NWDAF正在收集或已存储在所述数据获取状态为第二数据获取状态时，所述NWDAF的数据收集状态为数据完成所述第一网络设备在确定已有NWDAF和第二网络设备已存储与所述第一参数匹配的数据的情况下，通过网络存储功能NRF分别获得所述NWDAF和所述第二网络设备的负载状态，基于所述NWDAF和所述第二网络设备的负载状态确定目所述第一通讯单元，用于接收消费者发送的第一消息，所述设备未发现已有NWDAF正在收集或已存储与所述第一参数匹配的数据，通过网络存储功能5第一通讯单元接收所述数据提供者发送的与所述第一参所述第一参数；还用于通过所述第一通讯单元接收所述第二NWDAF发送的对应于所述第三消息的成功响应消息；还用于通过所述第一通讯单元接收所述第二NWDAF发送的与所述第设备发现已有NWDAF和第二网络设备已存储与所述第一参数匹配的数据，通过所述第一网基于所述NWDAF和所述第二网络设备的负载状态确定；还用于通过所述第一通讯单元向所述第四消息中至少包括所述第一参数；还用于通过所述第一通讯单元接收所述目标NWDAF发送的对应于所述第四消息的成功响应消息；判断所述目标NWDAF已存储的数据是否满足通讯单元接收所述目标NWDAF发送的与所述第一参数匹配所述第一通讯单元，还用于向所述服务消费者反馈所述数据分析6能NRF发现第二网络设备；通过所述第一通讯单元向所述第二网络设备发送用于请求数据用于通过所述第一通讯单元向所述第二网络设备发所述第二通讯单元，用于接收第一网络数据分析功能NWDAF发送的用于请求数据汇聚所述第一判断单元，用于基于所述数据的相关信息判断是否存在匹配所述第二通讯单元，还用于在所述第一判断单元确定存在匹配的数据所述第三通讯单元，用于处于正在收集数据状态时接收第一网络数据分析功能NWDAF所述第三通讯单元，还用于在确定正在收集的数据不满足所述第一参7所述确定单元，用于基于所述数据获取状态确定所述NWDAF的数据收集状态；所述NWDAF的数据收集状态包括数据正在收集状态或数据完成收所述第四通讯单元，还用于基于第一NWDAF的查询，向所述第一NWDAF在所述数据获取状态为第二数据获取状态时，所述NWDAF的数据收集状态为数据完成该程序被处理器执行时实现权利要求16至18任一所述处理器执行所述程序时实现权利要求16至18任一项所述方8[0010]所述第一NWDAF通过所述第一网络设备未发现已有NWDAF正在收集或已存储与所[0011]所述第一NWDAF向所述数据提供者发送第二消息；所述第二消息用于请求或订阅[0012]所述第一NWDAF接收所述数据提供者发送的对应于所述第二消息的成功响应消[0015]所述第一NWDAF通过所述第一网络设备发现正在收集与所述第一参数匹配的数据9[0019]所述第一NWDAF通过所述第一网络设备发现已有NWDAF和第二网络设备已存储与为所述NWDAF或所述第二网络设备；所述目标NWDAF基于所述NWDAF和所述第二网络设备的所述目标NWDAF发送的与所述第一参数匹配[0025]所述第一NWDAF向所述数据提供者发送第五消息；所述第五消息用于请求或订阅[0026]所述第一NWDAF接收所述数据提供者发送的对应于所述第五消息的成功响应消所述第一NWDAF向所述第一网络设备发送第六消息；所述第六消息用于注册或更新数据的[0031]所述第一NWDAF向所述第一网络设备发送用于注册或更新分析结果的第八消息；[0033]所述第一NWDAF向所述第二网络设备发送用于请求数据汇聚的第九消息，接收所述第二网络设备发送的对应于所述第九消息的[0037]第二网络设备接收第一NWDAF发送的用于请求数据汇聚的第九消息；所述第九消[0038]所述第二网络设备基于所述数据的相关信息判断是否存在匹配的数据正在传输输或已存储的情况下，所述第二网络设备向所述第一NWDAF发送对应于所述第九消息的拒不存在匹配的数据分析结果正在传输或已存储的情况下，所述第二网络设备向所述第一NWDAF发送对应于所述第九消息的成功[0042]所述第二网络设备在完成汇聚数据和/或数据分析结果时，向所述第一网络设备[0044]正在收集数据的第二NWDAF接收第一NWDAF发送的第三消息，向所述第一NWDAF发[0049]第一网络设备接收NWDAF发送的第十四消息，所述第十四消息用于注册或更新数[0052]在所述数据获取状态为第二数据获取状态时，所述NWDAF的数据收集状态为数据订阅NWDAF分析服务；所述第一消息中包括第一参数；所述第一参数至少包括以下至少之[0057]所述执行单元，用于根据所述查询单元获得的查询结果执行相应的数据收集策所述第一通讯单元接收所述第二NWDAF发送的对应于所述第三消息的成功响应消息；还用于通过所述第一通讯单元接收所述第二NWDAF发送的与所述第一参数匹配参数；还用于通过所述第一通讯单元接收所述目标NWDAF发送的对应于所述第四消息的成已存储的数据满足所述第一参数的情况下，通过所述第一通讯单元接收所述目标NWDAF发标NWDAF存储的第一数据；通过所述第一通讯单元接收所述数据提供者发送的对应于所述述第九消息中至少包括收集的数据的相关信息和向第一网络设备发送第十消息，所述第十消息用于注册或更新数据和/或分析结果的配置[0075]所述第三通讯单元，用于处于正在收集数据状态时接收第一NWDAF发送的第三消[0077]所述第三通讯单元，还用于在确定正在收集的数据不满足所述第一参数的情况[0083]在所述数据获取状态为第二数据获取状态时，所述NWDAF的数据收集状态为数据有NWDAF正在收集或已存储与所述第一参数匹配的数据，根据查询结果(例如未发现已有重用。[0102]本发明实施例提供了一种数据收集方法。图1为本发明实施例的数据收集方法的[0104]步骤102：在收集数据开始前，所述第一NWDAF通过第一网络设备查询是否已有NWDAF正在收集或已存储与所述第一参数匹配的数据，根据查询结果执行相应的数据收集类：第一类为第一NWDAF，第二类为NWDAF(第二NWDAF为第二类NWDAF中满足消费者需求的标识列表(EventIDlist)、事件标识集合(EventIDSet)或事件标识组(EventIDGroup)等方式表示。所述数据收集的时间参数可通过数据收集的时间段(timeperiodof一NWDAF通过所述第一网络设备未发现已有NWDAF正在收集或已存储与所述第一参数匹配息中至少包括所述第一参数；所述第一NWDAF接收所述数据提供者发送的对应于所述第二消息的成功响应消息；所述第一NWDAF接收所述数据提供者发送的与所述第一参数匹配的[0111]本实施例中，在没有任意NWDAF正在收集或已存储与所述第一参数匹配的数据的第一NWDAF可通过第一网络设备获得第二NWDAF的相关信息，向所述第二NWDAF发送第三消一NWDAF通过所述第一网络设备发现已有NWDAF和第二网络设备已存储与所述第一参数匹数匹配的数据；所述第四消息中至少包括所述第一参数；所述第一NWDAF接收所述目标NWDAF发送的对应于所述第四消息的成功响应消息；所述第一NWDAF判断所述目标NWDAF已存储的数据是否满足所述第一参数；在所述目标NWDAF已存储的数据满足所述第一参数的[0115]本实施例中，在存在已有NWDAF和第二网络设备已存储与所述第一参数匹配的数储的第一数据；所述第一NWDAF接收所述数据提供者发送的对应于所述第五消息的成功响[0117]本实施例中，在存在已有NWDAF和第二网络设备已存储与所述第一参数匹配的数一NWDAF通过NRF发现数据提供者，从数据提供者处获得未被目标NWDAF中存储的其余50个[0118]在本发明的一些可选实施例中，所述根据查询结果执行相应的数据收集策略之的，用于注册或更新数据的配置信息也可称为数据配置信息(profileofcollected[0119]本实施例中，所述第一网络设备可以为具有数据收集协调功能(DCCF，Data配置信息也可称为分析结果配置信息(profileofanaly网络切片标识具体可通过单一网络切片选择辅助信息(S-NSSAI，SingleNetworkSliceSelectionAssistanceIn所述第二网络设备发送的对应于所述第九消息的成功响应消息；所述第一NWDAF向所述第述第九消息中至少包括收集的数据的相关信息和[0126]步骤202：所述第二网络设备基于所述数据的相关信息判断是否存在匹配的数据果正在传输或已存储的情况下，所述第二网络设备向所述第一NWDAF发送对应于所述第九络设备向所述第一NWDAF发送对应于所述第九消息[0130]本实施例中，若第一NWDAF请求数据汇聚的数据是第二网络设备正在传输或已存网络设备未收集相关的数据或数据分析结果，则向所述第一NWDAF反馈对应于第九消息的成功响应消息，由第一NWDAF向所述第二网络设备发送所述第二网络设备中并未存储或并数据和/或分析结果的配置信息；所述第二网络设备在完成汇聚数据和/或数据分析结果NWDAF发送对应于所述第三消息的成功响应消息；所述第三消息用于请求或订阅与所述第但第二NWDAF正在收集的数据并非是消费者需要的完整数据，是消费者需要的完整数据中更新数据的配置信息，该配置信息中至少包括表示数据数据正在收集状态(collecting)态)。则第一网络设备可基于配置信息中的数据获取状态确定对应的NWDAF的数据收集状述NWDAF的数据收集状态为数据正在收集状态；在所述数据获取状态为第二数据获取状态[0145]本实施例中，在第一网络设备存储的第四配置信息中包所述第四配置信息中包括第二数据获取状态时，表示对应的NWDAF当前已完成对应的数据通过第一网络设备查询是否已有NWDAF正在收集或已存储与所述第一参数匹配的数据，如NWDAF的标识(ID)或地址以从该NWDAF处收集相关数据；如果未查到已有NWDAF正在收集和已存储与所述第一参数匹配的数据，则第一NWDAF与数据提供者直接进行交互以收集相关之一：事件标识列表(EventIDlist)、数据收集的时间段(Timeperiodofdata查询消息中包括上述第一参数，DCCF通过第一参数未发现已有NWDAF正在收集或已存储第[0165]示例性的，第一NWDAF通过前述实施例中的第二消息向数据提供者请求或订阅所[0168]示例性的，第一NWDAF可通过前述实施例中的第六消息注册或更新数据的配置信datacollection)、感兴趣的区域(AreaofInterest)、数据获取状态(Dataobtaining置信息为前述实施例中的第二配置信息，所述第二配置信息至少包括以下信息的至少之collection)、感兴趣的区域(AreaofInterest)、数据获取状态(Dataobtaining置信息为上述实施例中的第三配置信息，所述配置信息中至少包括以下信息的至少之一：NWDAF根据步骤504中发现的数据存储库发起交互请求，第一NWDAF在收到数据存储库的成据和/或分析结果的配置信息，结束汇聚数据和/或数据分析结果后再次在DCCF中注册/更应向DCCF发送不必要的查询请求。这些并置的NWDAF可以在数据收集过程中将配置文件注之一：事件标识列表(EventIDlist)、数据收集的时间段(Timeperiodofdata[0193]示例性的，第一NWDAF可通过前述实施例中的第六消息注册或更新数据的配置信datacollection)、感兴趣的区域(AreaofInterest)、数据获取状态(Dataobtaining费者所需的第一参数，则跳过步骤606a-步骤606d，若不完全满足则进行步骤606a-步骤[0197]示例性的，正在收集数据的第二NWDAF通过前述实施例中的第十三消息在DCCF中置信息为前述实施例中的第二配置信息，所述第二配置信息至少包括以下信息的至少之collection)、感兴趣的区域(AreaofInterest)、数据获取状态(Dataobtaining置信息为上述实施例中的第三配置信息，所述配置信息中至少包括以下信息的至少之一：已有相应的数据和/或数据分析结果正在传输或已存储，若存在重复汇聚则数据存储库向据和/或分析结果的配置信息；结束汇聚数据和/或数据分析结果后再次在DCCF中注册/更应向DCCF发送不必要的查询请求。这些并置的NWDAF可以在数据收集过程中将配置文件注之一：事件标识列表(EventIDlist)、数据收集的时间段(Timeperiodofdata查询消息中包括上述第一参数，DCCF分析输入参数发现有相应的NWDAF(第二NWDAF或数据存储库)已存储全部或部分所需数据和/或数[0219]示例性的，DCCF可从第二NWDAF和数据存储库中选择负载低的NWDAF作为目标[0224]示例性的，第一NWDAF通过前述实施例中的第四消息向数据存储库请求或订阅所[0227]示例性的，第一NWDAF可通过前述实施例中的第六消息注册或更新数据的配置信datacollection)、感兴趣的区域(AreaofInterest)、数据获取状态(Dataobtaining置信息为前述实施例中的第二配置信息，所述第二配置信息至少包括以下信息的至少之collection)、感兴趣的区域(AreaofInterest)、数据获取状态(Dataobtaining置信息为上述实施例中的第三配置信息，所述配置信息中至少包括以下信息的至少之一：数据存储库在收到请求时判断是否已有相应的数据和/或数据分析结果正在传输或已存[0243]步骤709d:数据存储库开始汇聚数据和/或数据分析结果时在DCCF中注册/更新数据和/或分析结果的配置信息；结束汇聚数据和/或数据分析结果后再次在DCCF中注册/更应向DCCF发送不必要的查询请求。这些并置的NWDAF可以在数据收集过程中将配置文件注发现已有NWDAF正在收集或已存储与所述第一参数匹配的数据，通过NRF发现数据提供者；接收所述数据提供者发送的与所述第一参数匹一参数；还用于通过所述第一通讯单元11接收所述第二NWDAF发送的对应于所述第三消息的成功响应消息；还用于通过所述第一通讯单元11接收所述第二NWDAF发送的与所述第一现已有NWDAF和第二网络设备已存储与所述第一参数匹配的数据，通过所述第一网络设备述NWDAF和所述第二网络设备的负载状态确定；还用于通过所述第一通讯单元11向所述目四消息中至少包括所述第一参数；还用于通过所述第一通讯单元11接收所述目标NWDAF发送的对应于所述第四消息的成功响应消息；判断所述目标NWDAF已存储的数据是否满足所讯单元11接收所述目标NWDAF发送的与所述第一参数匹配讯单元11向所述第二网络设备发送所述数中均可由中央处理器(CPU，CentralProcessingUnit)、数字信号处理器(DSP，DigitalSignalProcessor)、微控制单元(MCU，MicrocontrollerUnit)或可编程门阵列(FPGA，所述第九消息中至少包括收集的数据的相关信息和的数据正在传输或已存储，和/或，不存在匹配的数据分析结果正在传输或已存储的情况[0267]本发明实施例中，所述数据收集装置中的第一判断单元22，在实际应用中可由[0269]所述第三通讯单元31，用于处于正在收集数据状态时接收第一NWDAF发送的第三[0273]本发明实施例中，所述数据收集装置中的第二判断单元32，在实际应用中可由述NWDAF的数据收集状态为数据正在收集状态；在所述数据获取状态为第二数据获取状态第二网络设备的负载状态，基于所述NW