(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210347555.8 (22)申请日 2022.04.01 (71)申请人 山推工程机械股份有限公司 地址 272073 山 东省济宁市高新区327国道 58号 (72)发明人 桑坤　王加站　冯亚洲　杜永良　 韩珂　安茂众　 (74)专利代理 机构 北京品源专利代理有限公司 11332 专利代理师 高艳红 (51)Int.Cl. G06F 16/22(2019.01) G06F 16/23(2019.01) G06F 16/2455(2019.01) G06F 12/0877(2016.01)G06F 9/50(2006.01) (54)发明名称 一种数据存 储方法、 装置、 设备以及 介质 (57)摘要 本发明公开了一种数据存储方法、 装置、 设 备以及介质， 属于数据处理技术领域。 该方法包 括： 在存储模式订阅服务开启的情况下， 若监听 到数据消费者对目标数据进行消费， 则从候选存 储模式中选择所述目标数据关联的目标存储模 式； 采用所述目标存储模式对所述目标数据进行 存储。 通过上述技术方案， 实现了海量数据的差 异化存储。 权利要求书1页 说明书7页 附图3页 CN 114722043 A 2022.07.08 CN 114722043 A 1.一种数据存 储方法， 其特 征在于， 包括： 在存储模式订阅服务开启的情况下， 若监听到数据消费者对目标数据进行消费， 则从 候选存储模式中选择所述目标 数据关联的目标存 储模式； 采用所述目标存 储模式对所述目标 数据进行存 储。 2.根据权利要求1所述的方法， 其特征在于， 所述从候选存储模式中选择所述目标数据 关联的目标存 储模式， 包括： 根据目标消费主题和/或数据源， 从候选存储模式中选择目标数据关联的目标存储模 式。 3.根据权利要求1所述的方法， 其特征在于， 所述采用所述目标存储模式对所述目标数 据进行存 储， 包括： 将所述目标 数据缓存至内存队列； 根据预设的内存队列消费策略， 对所述目标 数据进行批量处 理； 采用所述目标存 储模式对处 理后的目标 数据进行存 储。 4.根据权利要求3所述的方法， 其特征在于， 所述采用所述目标存储模式对处理后的目 标数据进行存 储， 包括： 获取所述目标存 储模式对应的目标存 储模板； 将所述处 理后的目标 数据对应存 储至所述目标存 储模板中的映射字段。 5.根据权利要求3所述的方法， 其特 征在于， 所述对所述目标 数据进行批量处 理， 包括： 对所述目标 数据中的消息进行计数； 根据计数 结果， 对所述目标 数据进行批量处 理。 6.根据权利要求1所述的方法， 其特 征在于， 还 包括： 响应于对所述存储模式订阅服务的开启操作， 开启所述存储模式订阅服务， 并加载所 述候选存储模式。 7.根据权利要求1所述的方法， 其特 征在于， 还 包括： 响应于对至少两个原始数据的暂停存储和/或开启存储操作， 从所述至少两个原始数 据中选择目标 数据。 8.一种数据存 储装置， 其特 征在于， 包括： 目标存储模式确定模块， 用于在存储模式订阅服务开启的情况下， 若监听到数据消费 者对目标 数据进行消费， 则从候选存 储模式中选择所述目标 数据关联的目标存 储模式； 目标数据存储模块， 用于采用所述目标存 储模式对所述目标 数据进行存 储。 9.一种电子设备， 其特 征在于， 所述电子设备包括： 至少一个处 理器； 以及 与所述至少一个处 理器通信连接的存 储器； 其中， 所述存储器存储有可被所述至少一个处理器执行的计算机程序， 所述计算机程序被所 述至少一个处理器执行， 以使所述至少一个处理器能够执行权利要求1 ‑7中任一项所述的 数据存储方法。 10.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质存储有计算机指 令， 所述计算机指令用于使处 理器执行时实现权利要求1 ‑7中任一项所述的数据存 储方法。权　利　要　求　书 1/1 页 2 CN 114722043 A 2一种数据存 储方法、 装置、 设备以及介质 技术领域 [0001]本发明涉及数据处理技术领域， 尤其涉及一种数据存储方法、 装置、 设备以及介 质。 背景技术 [0002]近年来， 我国物联 网技术、 大数据技术被广泛应用到工程机械行业当中， 同时随着 国家、 地方政府对车辆定位、 车辆监控、 排放监管等需求， 使得工程机械行业不断朝着智能 化和信息化方向发展， 随之而来的是 大量的数据处 理存储需求。 [0003]目前， 在工程机械领域内， 大数据平台多采用Kafka这种高吞吐量的分布式发布订 阅消息系统， 但在面对快速变化的业务需求和多元化的查询需求时， 单一数据存储模式不 能满足业 务需求的快速迭代更新。 发明内容 [0004]本发明提供了一种数据存储方法、 装置、 设备以及介质， 以实现海量数据的差异化 存储。 [0005]根据本发明的一方面， 提供了一种数据存 储方法， 该 方法包括： [0006]在存储模式订阅服务开启的情况下， 若监听到数据消费者对 目标数据进行消费， 则从候选存 储模式中选择所述目标 数据关联的目标存 储模式； [0007]采用所述目标存 储模式对所述目标 数据进行存 储。 [0008]根据本发明的另一方面， 提供了一种数据存 储装置， 该装置包括： [0009]目标存储模式确定模块， 用于在存储模式订阅服务开启的情况下， 若监听到数据 消费者对目标数据进行消费， 则从候选存储模式中选择所述目标数据关联的目标存储模 式； [0010]目标数据存储模块， 用于采用所述目标存 储模式对所述目标 数据进行存 储。 [0011]根据本发明的另一方面， 提供了一种电子设备， 所述电子设备包括： [0012]至少一个处 理器； 以及 [0013]与所述至少一个处 理器通信连接的存 储器； 其中， [0014]所述存储器存储有可被所述至少一个 处理器执行的计算机程序， 所述计算机程序 被所述至少一个处理器执行， 以使所述至少一个处理器能够执行本发明任一 实施例所述的 数据存储方法。 [0015]根据本发明的另一方面， 提供了一种计算机可读存储介质， 所述计算机可读存储 介质存储有计算机指 令， 所述计算机指令用于使处理器执行时实现本发明任一实施例所述 的数据存 储方法。 [0016]本发明实施例的技术方案， 通过在存储模式订阅服务开启的情况下， 若监听到数 据消费者对目标数据进行消费， 则从候选存储模式中选择目标数据关联的目标存储模式， 之后采用目标存储模式对目标数据进行存储。 上述技术方案， 实现了对海量数据的差异化说　明　书 1/7 页 3 CN 114722043 A 3