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

在審

• 申請(qǐng)?zhí)枺?/td>: 202210338063.2
• 申請(qǐng)日: 2022-04-01
• 公開（公告）號(hào): CN114896033A
• 公開（公告）日: 2022-08-12
• 發(fā)明（設(shè)計(jì)）人: 彭垚;葛利亞;屈嘯;張?jiān)苿?/a>;劉平;周偉民;顧周超;王亞明
• 申請(qǐng)（專利權(quán)）人: 上海閃馬智能科技有限公司;杭州閃馬智擎科技有限公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48;G06F11/30
• 代理公司: 暫無信息
• 代理人: 暫無信息

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

獲取數(shù)據(jù)處理任務(wù)信息；

通過預(yù)設(shè)的第一分配算法，對(duì)所述數(shù)據(jù)處理任務(wù)信息進(jìn)行任務(wù)分配處理，以得到第一分配結(jié)果；

根據(jù)所述第一分配結(jié)果，向目標(biāo)引擎發(fā)送數(shù)據(jù)處理指令，以指示所述目標(biāo)引擎根據(jù)所述數(shù)據(jù)處理任務(wù)信息執(zhí)行數(shù)據(jù)處理操作；

所述方法還包括：

獲取推流開關(guān)指令，其中，所述推流開關(guān)指令用于指示所述目標(biāo)引擎執(zhí)行推流開關(guān)操作；

基于所述推流開關(guān)指令，存儲(chǔ)所述推流開關(guān)狀態(tài)；

在接收到推流更新請(qǐng)求的情況下，根據(jù)所述推流開關(guān)狀態(tài)，向所述目標(biāo)引擎發(fā)送推流開關(guān)信息，以指示所述目標(biāo)引擎執(zhí)行推流開關(guān)操作，其中，所述推流更新請(qǐng)求是所述目標(biāo)引擎在接收推到流變更信息的情況下發(fā)送的。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，在所述根據(jù)所述第一分配結(jié)果，向目標(biāo)引擎發(fā)送數(shù)據(jù)處理指令之后，所述方法還包括：

根據(jù)接收到的數(shù)據(jù)處理結(jié)果，確定任務(wù)處理狀態(tài)，其中，所述數(shù)據(jù)處理結(jié)果是所述目標(biāo)引擎執(zhí)行所述數(shù)據(jù)處理操作后反饋的；

在確定所述任務(wù)處理狀態(tài)為第一狀態(tài)的情況下，向第一引擎發(fā)送所述第一數(shù)據(jù)處理指令，以指示所述第一引擎執(zhí)行數(shù)據(jù)處理操作，其中，所述第一引擎為除所述目標(biāo)引擎以外的引擎；

在確定所述任務(wù)處理狀態(tài)為第二狀態(tài)的情況下，對(duì)所述數(shù)據(jù)處理任務(wù)信息進(jìn)行信息更新處理。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，在所述通過預(yù)設(shè)的第一分配算法，對(duì)所述數(shù)據(jù)處理任務(wù)信息進(jìn)行任務(wù)分配處理之前，所述方法還包括：

獲取所述目標(biāo)引擎的注冊(cè)信息；

基于所述注冊(cè)信息向所述目標(biāo)發(fā)送心跳監(jiān)控指令，以指示所述目標(biāo)引擎發(fā)送心跳信息，其中，所述心跳信息包括所述目標(biāo)引擎的實(shí)時(shí)工作狀態(tài)；

接收所述目標(biāo)引擎發(fā)送的心跳信息。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述通過預(yù)設(shè)的第一分配算法，對(duì)所述數(shù)據(jù)處理任務(wù)信息進(jìn)行任務(wù)分配處理，以得到第一分配結(jié)果包括：

基于所述數(shù)據(jù)處理任務(wù)信息，確定所述第一分配算法中的因素權(quán)重；

基于所述因素權(quán)重以及所述數(shù)據(jù)處理任務(wù)信息，執(zhí)行所述任務(wù)分配處理，以得到所述第一分配結(jié)果。

5.一種數(shù)據(jù)處理裝置，其特征在于，包括：

信息采集模塊，用于獲取數(shù)據(jù)處理任務(wù)信息；

任務(wù)分配模塊，用于通過預(yù)設(shè)的第一分配算法，對(duì)所述數(shù)據(jù)處理任務(wù)信息進(jìn)行任務(wù)分配處理，以得到第一分配結(jié)果；

指令發(fā)送模塊，用于根據(jù)所述第一分配結(jié)果，向目標(biāo)引擎發(fā)送數(shù)據(jù)處理指令，以指示所述目標(biāo)引擎根據(jù)所述數(shù)據(jù)處理任務(wù)信息執(zhí)行數(shù)據(jù)處理操作；

其中，所述裝置還包括：

推流指令采集模塊，用于獲取推流開關(guān)指令，其中，所述推流開關(guān)指令用于指示所述目標(biāo)引擎執(zhí)行推流開關(guān)操作；

指令存儲(chǔ)模塊，用于基于所述推流開關(guān)指令，存儲(chǔ)所述推流開關(guān)狀態(tài)；

信息發(fā)送模塊，用于在接收到推流更新請(qǐng)求的情況下，根據(jù)所述推流開關(guān)狀態(tài)，向所述目標(biāo)引擎發(fā)送推流開關(guān)信息，以指示所述目標(biāo)引擎執(zhí)行推流開關(guān)操作，其中，所述推流更新請(qǐng)求是所述目標(biāo)引擎在接收推到流變更信息的情況下發(fā)送的。

6.根據(jù)權(quán)利要求5所述的裝置，其特征在于，所述裝置還包括：

任務(wù)狀態(tài)確定模塊，用于根據(jù)接收到的數(shù)據(jù)處理結(jié)果，確定任務(wù)處理狀態(tài)，其中，所述數(shù)據(jù)處理結(jié)果是所述目標(biāo)引擎執(zhí)行所述數(shù)據(jù)處理操作后反饋的；

第一指令發(fā)送模塊，用于在所述根據(jù)所述第一分配結(jié)果，向目標(biāo)引擎發(fā)送數(shù)據(jù)處理指令之后，在確定所述任務(wù)處理狀態(tài)為第一狀態(tài)的情況下，向第一引擎發(fā)送所述第一數(shù)據(jù)處理指令，以指示所述第一引擎執(zhí)行數(shù)據(jù)處理操作，其中，所述第一引擎為除所述目標(biāo)引擎以外的引擎；

信息更新模塊，用于在確定所述任務(wù)處理狀態(tài)為第二狀態(tài)的情況下，對(duì)所述數(shù)據(jù)處理任務(wù)信息進(jìn)行信息更新處理。