[發(fā)明專利]直播數(shù)據(jù)的處理方法、裝置、電子設(shè)備及存儲(chǔ)介質(zhì)

有效

• 申請?zhí)枺?/td>: 202110477733.4
• 申請日: 2021-04-30
• 公開（公告）號(hào): CN113329233B
• 公開（公告）日: 2022-09-09
• 發(fā)明（設(shè)計(jì)）人: 蘇永圳;程企堯
• 申請（專利權(quán)）人: 北京達(dá)佳互聯(lián)信息技術(shù)有限公司
• 主分類號(hào): H04N21/2187
• 分類號(hào): H04N21/2187;H04N21/242;H04N21/426;H04N21/43;H04N21/443;H04N21/4788
• 代理公司: 廣州三環(huán)專利商標(biāo)代理有限公司 44202
• 代理人: 郝傳鑫;賈允

1.一種直播數(shù)據(jù)的處理方法，其特征在于，所述方法包括：

獲取垂類配置信息，確定所述垂類配置信息中各目標(biāo)垂類的同步配置信息和計(jì)算配置信息；

針對每個(gè)所述目標(biāo)垂類，根據(jù)所述目標(biāo)垂類的同步配置信息生成并執(zhí)行對應(yīng)的同步分片任務(wù)以進(jìn)行數(shù)據(jù)同步處理，得到所述目標(biāo)垂類的數(shù)據(jù)同步結(jié)果信息，并將所述數(shù)據(jù)同步結(jié)果信息存儲(chǔ)在所述目標(biāo)垂類對應(yīng)的第一緩存節(jié)點(diǎn)，所述數(shù)據(jù)同步結(jié)果信息包括所述目標(biāo)垂類和所述目標(biāo)垂類對應(yīng)的主播標(biāo)識(shí)；

根據(jù)所述目標(biāo)垂類的計(jì)算配置信息和所述目標(biāo)垂類的數(shù)據(jù)同步結(jié)果信息，生成并執(zhí)行對應(yīng)的計(jì)算分片任務(wù)以從直播實(shí)時(shí)數(shù)據(jù)集合中確定所述目標(biāo)垂類的直播實(shí)時(shí)數(shù)據(jù)，所述目標(biāo)垂類的直播實(shí)時(shí)數(shù)據(jù)為所述目標(biāo)垂類對應(yīng)的主播標(biāo)識(shí)中處于開播狀態(tài)的主播標(biāo)識(shí)的直播實(shí)時(shí)數(shù)據(jù)。

2.根據(jù)權(quán)利要求1所述的直播數(shù)據(jù)的處理方法，其特征在于，所述根據(jù)所述目標(biāo)垂類的同步配置信息生成并執(zhí)行對應(yīng)的同步分片任務(wù)以進(jìn)行數(shù)據(jù)同步處理，得到所述目標(biāo)垂類的數(shù)據(jù)同步結(jié)果信息，包括：

將所述目標(biāo)垂類的同步配置信息發(fā)送至所述目標(biāo)垂類對應(yīng)的同步目標(biāo)節(jié)點(diǎn)，由所述同步目標(biāo)節(jié)點(diǎn)根據(jù)所述目標(biāo)垂類的同步配置信息生成所述目標(biāo)垂類的同步分片任務(wù)；

由所述同步目標(biāo)節(jié)點(diǎn)執(zhí)行所述目標(biāo)垂類的同步分片任務(wù)，得到所述目標(biāo)垂類的數(shù)據(jù)同步結(jié)果信息，所述數(shù)據(jù)同步結(jié)果信息包括所述目標(biāo)垂類和所述目標(biāo)垂類對應(yīng)的主播標(biāo)識(shí)。

3.根據(jù)權(quán)利要求2所述的直播數(shù)據(jù)的處理方法，其特征在于，所述由所述同步目標(biāo)節(jié)點(diǎn)執(zhí)行所述目標(biāo)垂類的同步分片任務(wù)，得到所述目標(biāo)垂類的數(shù)據(jù)同步結(jié)果信息，包括：

根據(jù)所述同步配置信息中的同步數(shù)據(jù)索引信息，確定所述目標(biāo)垂類的主播數(shù)據(jù)表；

根據(jù)所述主播數(shù)據(jù)表，得到所述目標(biāo)垂類對應(yīng)的主播標(biāo)識(shí)；

根據(jù)所述目標(biāo)垂類和所述目標(biāo)垂類對應(yīng)的主播標(biāo)識(shí)得到所述目標(biāo)垂類的數(shù)據(jù)同步結(jié)果信息，并將所述數(shù)據(jù)同步結(jié)果信息存儲(chǔ)在所述目標(biāo)垂類對應(yīng)的第一緩存節(jié)點(diǎn)。

4.根據(jù)權(quán)利要求1所述的直播數(shù)據(jù)的處理方法，其特征在于，所述根據(jù)所述目標(biāo)垂類的計(jì)算配置信息和所述目標(biāo)垂類的數(shù)據(jù)同步結(jié)果信息，生成并執(zhí)行對應(yīng)的計(jì)算分片任務(wù)以從直播實(shí)時(shí)數(shù)據(jù)集合中確定所述目標(biāo)垂類的直播實(shí)時(shí)數(shù)據(jù)，包括：

將所述目標(biāo)垂類的計(jì)算配置信息發(fā)送至所述目標(biāo)垂類對應(yīng)的計(jì)算目標(biāo)節(jié)點(diǎn)，由所述計(jì)算目標(biāo)節(jié)點(diǎn)根據(jù)所述目標(biāo)垂類的計(jì)算配置信息生成所述目標(biāo)垂類的計(jì)算分片任務(wù)；

由所述計(jì)算目標(biāo)節(jié)點(diǎn)執(zhí)行所述目標(biāo)垂類的計(jì)算分片任務(wù)，根據(jù)所述目標(biāo)垂類的數(shù)據(jù)同步結(jié)果信息從直播實(shí)時(shí)數(shù)據(jù)集合中確定所述目標(biāo)垂類的直播實(shí)時(shí)數(shù)據(jù)。

5.根據(jù)權(quán)利要求4所述的直播數(shù)據(jù)的處理方法，其特征在于，所述由所述計(jì)算目標(biāo)節(jié)點(diǎn)執(zhí)行所述目標(biāo)垂類的計(jì)算分片任務(wù)，根據(jù)所述目標(biāo)垂類的數(shù)據(jù)同步結(jié)果信息從直播實(shí)時(shí)數(shù)據(jù)集合中確定所述目標(biāo)垂類的直播實(shí)時(shí)數(shù)據(jù)，包括：

從所述目標(biāo)垂類對應(yīng)的第一緩存節(jié)點(diǎn)，確定所述目標(biāo)垂類的主播標(biāo)識(shí)；

從直播實(shí)時(shí)數(shù)據(jù)集合中確定所述目標(biāo)垂類的主播標(biāo)識(shí)中處于開播狀態(tài)的主播標(biāo)識(shí)對應(yīng)的直播實(shí)時(shí)數(shù)據(jù)。

6.根據(jù)權(quán)利要求1至5中任一項(xiàng)所述的直播數(shù)據(jù)的處理方法，其特征在于，所述方法還包括：

根據(jù)所述目標(biāo)垂類的計(jì)算配置信息中的直播數(shù)據(jù)指標(biāo)，確定所述直播實(shí)時(shí)數(shù)據(jù)的直播數(shù)據(jù)指標(biāo)值；

根據(jù)所述直播數(shù)據(jù)指標(biāo)對應(yīng)的指標(biāo)權(quán)重和所述直播實(shí)時(shí)數(shù)據(jù)的直播數(shù)據(jù)指標(biāo)值，對所述直播實(shí)時(shí)數(shù)據(jù)進(jìn)行排序，得到所述目標(biāo)垂類的目標(biāo)直播實(shí)時(shí)數(shù)據(jù)。

7.根據(jù)權(quán)利要求1至5中任一項(xiàng)所述的直播數(shù)據(jù)的處理方法，其特征在于，所述方法還包括：

根據(jù)所述目標(biāo)垂類的計(jì)算配置信息確定所述目標(biāo)垂類的數(shù)據(jù)過濾條件；

基于所述目標(biāo)垂類的數(shù)據(jù)過濾條件，對所述目標(biāo)垂類的直播實(shí)時(shí)數(shù)據(jù)進(jìn)行過濾，得到過濾后的直播實(shí)時(shí)數(shù)據(jù)。

8.根據(jù)權(quán)利要求1至5中任一項(xiàng)所述的直播數(shù)據(jù)的處理方法，其特征在于，所述方法還包括：

響應(yīng)于終端發(fā)送的目標(biāo)垂類數(shù)據(jù)獲取請求，發(fā)送所述目標(biāo)垂類的直播實(shí)時(shí)數(shù)據(jù)至終端，以使所述終端展示所述目標(biāo)垂類的直播實(shí)時(shí)數(shù)據(jù)。