技术摘要：
本发明实施例公开了一种数据处理方法、装置、数据处理设备以及存储介质，其中方法包括：响应于确定数量阈值的触发指令，获取用于表示消息时效性的时效参数，数量阈值表示从服务器获取消息的最大数量；基于时效参数确定目标数量，并根据目标数量确定数量阈值，其中，在  全部
背景技术：
随着科技的不断发展，大多数行业致力于为用户生产生活提供更多便利，比如智 慧公路、安全辅助驾驶产品可以保证用户更加安全地驾驶。在这类产品实现中，每个路段安 装消息采集设备，用于采集该路段上的路段消息比如车辆行驶情况、事故情况、拥堵情况等 等；消息采集设备将采集到的路段消息实时上传到服务器中，车辆行驶至该路段时可以从 服务器中获取路段消息，并根据该路段消息提示用户路段情况，以方便用户调整驾驶方案， 提高驾驶的安全性。 对于车辆来说，从服务器获取的消息越多，对当前路段的路段情况的评估越准确。 但是，车辆每次从服务器请求一条消息均需要消耗一定的网络带宽资源，请求的消息越多 需要消耗的网路带宽资源越多。综上所述，为了提高网络带宽资源的利用率，车辆不能从服 务器获取无限制的消息，需要设置从服务器获取消息的数量阈值，在能够保证车辆依据获 取到的消息更好的执行业务的同时，尽可能保证较高的网络带宽资源利用率。因此，当前如 何有效地确定数量阈值成为研究的热点问题。
技术实现要素：
本发明实施例提供了一种数据处理方法、装置、数据处理设备及存储介质，可以有 效地确定从服务器获取消息的数量。 一方面，本发明实施例提供了一种数据处理方法，包括： 响应于确定数量阈值的触发指令，获取用于表示消息的时效性的时效参数； 基于所述时效参数确定目标数量，并根据所述目标数量确定数量阈值，其中，所述 数量阈值表示从服务器获取消息的最大数量； 其中，在从服务器获取消息时，是按照所述服务器中多个消息的存储时间获取目 标消息，获取的目标消息的数量小于或等于所述数量阈值，且每个目标消息的时效性均满 足时效性条件； 存储所述数量阈值。 一方面，本发明实施例提供了一种数据处理装置，包括： 获取单元，用于响应于确定数量阈值的触发指令，获取用于表示消息的时效性的 时效参数，所述数量阈值表示从服务器获取消息的最大数量； 处理单元，用于基于所述时效参数确定目标数量，并根据所述目标数量确定数量 阈值，其中，在从服务器获取消息时，是按照所述服务器中多个消息的存储时间获取目标消 息，获取的目标消息的数量小于或等于所述数量阈值，且每个目标消息的时效性均满足时 效性条件； 4 CN 111586160 A 说　明　书 2/17 页 存储单元，用于存储所述数量阈值。 在一个实施例中，所述触发指令包括接收到所述服务器发送的存储的消息的总数 量发生更改的通知消息；或者，所述触发指令包括检测到从所述服务器获取消息的消息获 取指令且未获取到已存储数量阈值。 在一个实施例中，所述触发指令包括检测到从所述服务器获取消息的消息获取指 令且未获取到已存储数量阈值，所述装置还包括发送单元和接收单元： 所述接收单元，用于向所述服务器发送携带请求数量的消息获取请求，所述消息 获取请求用于指示所述服务器依据所述服务器中多个消息被存储时间由后向前的顺序选 择并返回所述请求数量个目标消息，所述请求数量和当前已从服务器获取到消息的已获取 数量之和小于或等于所述数量阈值； 所述接收单元，用于接收所述服务器返回的所述目标消息；所述处理单元，还用于 基于所述目标消息执行业务。 在一个实施例中，所述时效参数包括时效性衰减因子，所述获取单元在获取用于 表示消息时效性的时效参数时，执行如下操作：获取所述服务器中存储消息的总数量；对所 述总数量进行预设运算，并根据运算得到的结果确定时效性衰减因子。 在一个实施例中，所述时效参数还包括时效性等级基数和时效性贡献率阈值，所 述获取单元在获取所述时效参数时，执行如下操作：获取时效性等级基数；根据所述时效性 等级基数和所述时效性衰减因子确定时效性贡献率阈值的取值范围；从所述取值范围内获 取所述时效性贡献率阈值。 在一个实施例中，所述获取单元在根据所述时效性等级基数和所述时效性衰减因 子确定时效性贡献率阈值的取值范围时，执行如下操作：基于所述时效性基数和所述时效 性衰减因子确定总时效性贡献率；对所述总时效性贡献率进行预设运算，得到最小时效性 贡献率；获取最大时效性贡献率，并根据所述最小时效性贡献率和所述最大时效性贡献率 组成所述时效性贡献率阈值的取值范围。 在一个实施例中，所述获取单元在基于所述时效性基数和所述时效性衰减因子确 定总时效性贡献率时，执行如下操作：基于所述时效性基数和所述时效性衰减因子确定所 述每个消息的时效性等级；对所述每个消息的时效性等级进行求和运算确定总时效性等 级，并基于每个消息的时效性等级与所述总时效性等级确定所述每个消息的时效性贡献 率；对所述每个消息的时效性贡献率进行求和运算确定总时效性贡献率。 在一个实施例中，所述获取单元在基于所述时效性基数和所述时效性衰减因子确 定所述每个消息的时效性等级，执行如下操作：基于所述服务器中每个消息被存储的次序 和所述时效性衰减因子确定所述每个消息的时效性等级系数；对所述时效性等级基数和所 述每个消息的时效性等级系数进行预设运算，得到每个消息的时效性等级。 在一个实施例中，所述服务器与目标路段对应，所述目标路段上部署消息采集设 备，所述消息采集设备用于采集不同时刻所述目标路段上的路段消息，所述路段消息包括 所述目标路段上的车辆行驶消息和所述目标路段上的路况消息；所述服务器中存储的消息 包括所述消息采集设备采集到的路段消息，所述路段消息是以存储队列的形式依序存储在 所述服务器中，其中，越先接收到的路段消息存储越靠前，越后接收到的路段消息存储越靠 后。 5 CN 111586160 A 说　明　书 3/17 页 在一个实施例中，所述服务器返回的所述目标数量个消息中包括所述目标路段上 的路段消息，所述业务包括驾驶风险提示业务，所述处理单元在基于接收到的所述目标数 量个目标消息执行业务时，执行如下操作：基于所述目标数量个消息和驾驶风险评估模型 获取在所述目标路段上驾驶的驾驶风险值；获取所述目标路段对应的驾驶风险阈值；若所 述驾驶风险值大于所述驾驶风险阈值，则输出提示消息。 一方面，本发明实施例提供了一种数据处理设备，其特征在于，包括：处理器，适于 实现一条或多条指令；以及， 计算机存储介质，所述计算机存储介质存储有一条或多条指令，所述一条或多条 指令适于由所述处理器加载并执行如下步骤： 响应于确定数量阈值的触发指令，获取用于表示消息的时效性的时效参数，所述 数量阈值表示从服务器获取消息的最大数量； 基于所述时效参数确定目标数量，并根据所述目标数量确定数量阈值，其中，在从 服务器获取消息时，是按照所述服务器中多个消息的存储时间获取目标消息，获取的目标 消息的数量小于或等于所述数量阈值，且每个目标消息的时效性均满足时效性条件； 存储所述数量阈值。 一方面，本发明实施例提供了一种计算机存储介质，其特征在于，所述计算机存储 介质中存储有计算机程序指令，所述计算机程序指令被处理器执行时，用于执行如下步骤： 响应于确定数量阈值的触发指令，获取用于表示消息的时效性的时效参数，所述 数量阈值表示从服务器获取消息的最大数量； 基于所述时效参数确定目标数量，并根据所述目标数量确定数量阈值，其中，在从 服务器获取消息时，是按照所述服务器中多个消息的存储时间获取目标消息，获取的目标 消息的数量小于或等于所述数量阈值，且每个目标消息的时效性均满足时效性条件； 存储所述数量阈值。 本发明实施例中，当检测到需要确定数量阈值的触发指令时，获取用于表示消息 时效性的时效参数，所述数量阈值表示从服务器获取消息的最大数量；然后，基于时效参数 确定目标数量，进一步的，根据目标数量确定并存储数量阈值。当从服务器获取消息时，按 照多个消息的存储时间获取目标消息，目标消息的数量小于或等于数量阈值，这样一来，可 以保证每个目标消息的时效性均满足时效性条件。应当理解的，各个消息存储到服务器的 时间不同，越早存储的消息对执行业务的参考价值越小。在上述确定数量阈值过程中，数量 阈值的确定参考了时效参数，如果根据该数量阈值从服务器获取信息可以保证获取到消息 对执行业务有较高参考价值的信息，实现了有效地确定数量阈值，从而可以保证数据处理 设备依据获取到的消息更好的执行业务的同时，尽可能保证较高的网络带宽资源利用率。 附图说明 为了更清楚地说明本发明实施例技术方案，下面将对实施例描述中所需要使用的 附图作简单地介绍，显而易见地，下面描述中的附图是本发明的一些实施例，对于本领域普 通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。 图1是本发明实施例提供的一种数据处理系统的结构示意图； 图2是本发明实施例提供的一种数据处理方法的流程示意图； 6 CN 111586160 A 说　明　书 4/17 页 图3是本发明实施例提供的另一种数据处理方法的流程示意图； 图4是本发明实施例提供的一种数据处理方法应用的应用场景图； 图5是本发明实施例提供的一种数据处理装置的结构示意图； 图6是本发明实施例提供一种数据处理设备的结构示意图。