技术摘要：
本公开关于一种数据处理方法、装置、电子设备及存储介质，以至少解决相关技术中的直播互动数据管理方案存在的直播互动数据的获取逻辑复杂、查询效率低的问题。所述方法包括：根据预置的实时数据表中存储的直播互动数据的记录标识和预先设置的归档条件，读取所述实时数  全部
背景技术：
随着网络技术的不断发展，网络直播已成为一种新兴的社交方式。在网络直播中， 各主播之间可以进行直播对决PK，即一个主播在进行直播时可以对其他主播发起挑战，一 旦其他主播接受挑战，两个直播间的主播就开始进行连麦互动，各主播的粉丝通过点赞、刷 礼物等方式为自己的主播增加人气，通过统计各主播最终的人气度来决定胜负。 网络直播平台上每日会产生多场的直播对决，每场直播对决过程中产生的直播互 动数据的数据量较大，随着数据量的不断上升最终将会影响到数据库操作。根据此，相关技 术中的直播互动数据管理方案通常采用分表存储的方式，即将数据库中存储的所有直播互 动数据散列到多张数据表中。然而，随着直播互动数据的数据量增加，采用的分表增多，将 增加直播互动数据的获取逻辑的复杂度，降低了直播互动数据的查询效率。
技术实现要素：
本公开提供一种数据处理方法、装置及系统，以至少解决相关技术中的直播互动 数据管理方案存在的直播互动数据的获取逻辑复杂、查询效率低的问题。本公开的技术方 案如下： 根据本公开实施例的第一方面，提供一种数据处理方法，包括： 根据预置的实时数据表中存储的直播互动数据的记录标识和预先设置的归档条 件，读取所述实时数据表中待归档的直播互动数据，其中，所述实时数据表存储有直播互动 过程中实时产生的直播互动数据，所述记录标识用于指示直播互动数据的产生顺序和/或 产生时间，所述待归档的直播互动数据包括记录标识所指示的产生顺序和/或产生时间满 足所述归档条件的直播互动数据； 将所述待归档的直播互动数据存储至用于存储历史直播互动数据的归档数据表 中。 可选地，所述将所述待归档的直播互动数据存储至用于存储历史直播互动数据的 归档数据表中，包括： 根据所述待归档的直播互动数据的记录标识，将所述待归档的直播互动数据分批 插入所述归档数据表中并在插入成功后将所述待归档的直播互动数据从所述实时数据表 中删除。 可选地，所述直播互动数据的记录标识包括所述直播互动数据的顺序标识和/或 产生时间； 所述归档条件包括： 所述顺序标识与所述实时数据表存储的直播互动数据中的最大顺序标识之间的 4 CN 111581432 A 说　明　书 2/12 页 绝对差值大于预设阈值，和/或，所述产生时间与当前时间之间的时间间隔大于预设时间间 隔。 可选地，在所述根据预置的实时数据表中存储的直播互动数据的记录标识和预先 设置的归档条件，读取所述实时数据表中待归档的直播互动数据之前，所述方法还包括： 获取最大归档记录标识，所述最大归档记录标识是指所述归档数据表中产生顺序 位于最后和/或产生时间距离当前时间最近的历史直播互动数据的记录标识； 所述根据预置的实时数据表中存储的直播互动数据的记录标识和预先设置的归 档条件，读取所述实时数据表中待归档的直播互动数据，包括： 从所述最大归档记录标识起遍历所述实时数据表； 对于遍历到的每一直播互动数据，若所述直播互动数据的记录标识所指示的产生 顺序和/或产生时间满足所述归档条件，则从所述实时数据表中读取出所述直播互动数据。 可选地，在所述将所述待归档的直播互动数据存储至用于存储历史直播互动数据 的归档数据表中之后，所述方法还包括： 根据所述待归档的直播互动数据的记录标识更新所述最大归档记录标识。 可选地，所述方法还包括： 接收直播互动业务的查询请求，所述查询请求中携带指定记录标识； 根据所述指定记录标识和最大归档记录标识，获取所述指定记录标识对应的直播 互动数据所属的目标数据表，所述目标数据表包括所述实时数据表或所述归档数据表，所 述最大归档记录标识是指所述归档数据表中产生顺序位于最后和/或产生时间距离当前时 间最近的历史直播互动数据的记录标识； 从所述目标数据表中读取所述指定记录标识对应的直播互动数据并反馈给所述 直播互动业务。 可选地，所述根据所述指定记录标识和最大归档记录标识，获取所述指定记录标 识对应的直播对决数据所属的目标数据表，包括： 若所述指定记录标识所指示的产生时间在所述最大归档记录标识所指示的产生 时间之后和/或所述指定记录标识所指示的产生顺序位于所述最大归档记录标识指示的产 生顺序之后，则获取所述实时数据表； 若所述指定记录标识所指示的产生时间不超过所述最大归档记录标识所指示的 产生时间和/或所述指定记录标识所指示的产生顺序不超过所述最大归档记录标识所指示 的产生顺序，则获取所述归档数据表。 可选地，所述方法还包括： 接收到直播互动业务的打点请求，所述打点请求用于请求统计分析所述直播互动 业务对应的直播互动数据； 响应于所述打点请求，扫描所述实时数据表以获取所述直播互动业务对应的直播 互动数据； 对所述直播互动业务对应的直播互动数据进行打点。 根据本公开实施例的第二方面，提供一种数据处理装置，包括： 第一确定单元，被配置为执行根据预置的实时数据表中存储的直播互动数据的记 录标识和预先设置的归档条件，读取所述实时数据表中待归档的直播互动数据，其中，所述 5 CN 111581432 A 说　明　书 3/12 页 实时数据表存储有直播互动过程中实时产生的直播互动数据，所述记录标识用于指示直播 互动数据的产生顺序和/或产生时间，所述待归档的直播互动数据包括记录标识所指示的 产生顺序和/或产生时间满足所述归档条件的直播互动数据； 迁移单元，被配置为执行将所述待归档的直播互动数据存储至用于存储历史直播 互动数据的归档数据表中。 可选地，所述迁移单元具体被配置为执行： 根据所述待归档的直播互动数据的记录标识，将所述待归档的直播互动数据分批 插入所述归档数据表中并在插入成功后将所述待归档的直播互动数据从所述实时数据表 中删除。 可选地，所述直播互动数据的记录标识包括所述直播互动数据的顺序标识和/或 产生时间； 所述归档条件包括： 所述顺序标识与所述实时数据表存储的直播互动数据中的最大顺序标识之间的 绝对差值大于预设阈值，和/或，所述产生时间与当前时间之间的时间间隔大于预设时间间 隔。 可选地，所述装置还包括： 第一获取单元，被配置为执行在所述第一确定单元根据预置的实时数据表中存储 的直播互动数据的记录标识和预先设置的归档条件，读取所述实时数据表中待归档的直播 互动数据之前，获取最大归档记录标识，所述最大归档记录标识是指所述归档数据表中产 生顺序位于最后和/或产生时间距离当前时间最近的历史直播互动数据的记录标识； 所述第一确定单元具体被配置为执行： 从所述最大归档记录标识起遍历所述实时数据表； 对于遍历到的每一直播互动数据，若所述直播互动数据的记录标识所指示的产生 顺序和/或产生时间满足所述归档条件，从所述实时数据表中读取出所述直播互动数据。 可选地，所述装置还包括： 更新单元，被配置为执行在所述迁移单元将所述待归档的直播互动数据存储至用 于存储历史直播互动数据的归档数据表中之后，根据所述待归档的直播互动数据的记录标 识更新所述最大归档记录标识。 可选地，所述装置还包括： 第一接收单元，被配置为执行接收直播互动业务的查询请求，所述查询请求中携 带指定记录标识； 第二确定单元，被配置为执行根据所述指定记录标识和最大归档记录标识，获取 所述指定记录标识对应的直播互动数据所属的目标数据表，所述目标数据表包括所述实时 数据表或所述归档数据表，所述最大归档记录标识是指所述归档数据表中产生顺序位于最 后和/或产生时间距离当前时间最近的历史直播互动数据的记录标识； 读取单元，被配置为执行从所述目标数据表中读取所述指定记录标识对应的直播 互动数据并反馈给所述直播互动业务。 可选地，所述第二确定单元具体被配置为执行： 若所述指定记录标识所指示的产生时间在所述最大归档记录标识所指示的产生 6 CN 111581432 A 说　明　书 4/12 页 时间之后和/或所述指定记录标识所指示的产生顺序位于所述最大归档记录标识指示的产 生顺序之后，则获取所述实时数据表； 若所述指定记录标识所指示的产生时间不超过所述最大归档记录标识所指示的 产生时间和/或所述指定记录标识所指示的产生顺序不超过所述最大归档记录标识所指示 的产生顺序之前，则获取所述归档数据表。 可选地，所述装置还包括： 第二接收单元，被配置为执行接收到直播互动业务的打点请求，所述打点请求用 于请求统计分析所述直播互动业务对应的直播互动数据； 扫描单元，被配置为执行响应于所述打点请求，扫描所述实时数据表以获取所述 直播互动业务对应的直播互动数据； 打点单元，被配置为执行对所述直播互动业务对应的直播互动数据进行打点。 根据本公开实施例的第三方面，提供一种电子设备，包括： 处理器； 用于存储所述处理器可执行指令的存储器； 其中，所述处理器被配置为执行所述指令，以实现第一方面所述的数据处理方法。 根据本公开实施例的第四方面，提供一种存储介质，当所述存储介质中的指令由 电子设备的处理器执行时，使得电子设备能够执行第一方面所述的数据处理方法。 根据本公开实施例的第五方面，提供一种计算机程序产品，包括一条或多条指令， 该指令可以由电子设备是处理器执行时，使得电子设备能够执行第一方面所述的数据处理 方法。 本公开的实施例提供的技术方案至少带来以下有益效果： 根据预置的实时数据表中存储的直播互动数据的记录标识和预先设置的归档条 件，读取所述实时数据表中待归档的直播互动数据，所述记录标识用于指示直播互动数据 的产生顺序和/或产生时间，并将所述待归档的直播互动数据存储至用于存储历史直播互 动数据的归档数据表中，使得所述实时数据表中存储使用频率较高、较活跃的直播互动数 据，而所述归档数据表中存储使用频率较低、不活跃的历史直播互动数据，由此，一方面可 以有效控制所述实时数据表中的数据量，进而可以提高对所述实时数据表的查询和更新效 率，使得所述实时数据表能够支持更高要求的读写请求；另一方面，可以减少使用频率低、 不活跃的直播互动数据对线上资源的占用。此外，本公开实施例提供的数据处理方法仅采 用两张数据表，相较于相关技术中将所有直播互动数据散列存储在大量数据表的方式，可 以简化对直播互动数据的获取逻辑。 应当理解的是，以上的一般描述和后文的细节描述仅是示例性和解释性的，并不 能限制本公开。 附图说明 此处的附图被并入说明书中并构成本说明书的一部分，示出了符合本公开的实施 例，并与说明书一起用于解释本公开的原理，并不构成对本公开的不当限定。 图1是根据一示例性实施例示出的一种数据处理方法的流程图。 图2是根据一示例性实施例示出的一种数据处理方法的交互图。 7 CN 111581432 A 说　明　书 5/12 页 图3是根据一示例性实施例示出的一种数据处理装置的框图。 图4是根据一示例性实施例示出的另一种数据处理装置的框图。 图5是根据一示例性实施例示出的一种电子设备的框图。