[發(fā)明專利]數(shù)據(jù)流處理方法及裝置

在審

• 申請?zhí)枺?/td>: 202110314078.0
• 申請日: 2021-03-24
• 公開（公告）號: CN113065029A
• 公開（公告）日: 2021-07-02
• 發(fā)明（設(shè)計）人: 程企堯
• 申請（專利權(quán)）人: 北京達佳互聯(lián)信息技術(shù)有限公司
• 主分類號: G06F16/90
• 分類號: G06F16/90;G06F16/70
• 代理公司: 北京集佳知識產(chǎn)權(quán)代理有限公司 11227
• 代理人: 劉猛

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

獲取內(nèi)容源數(shù)據(jù)流；

轉(zhuǎn)換所述內(nèi)容源數(shù)據(jù)流的數(shù)據(jù)格式為預(yù)設(shè)數(shù)據(jù)格式得到待處理數(shù)據(jù)流；

獲取與業(yè)務(wù)場景相匹配的數(shù)據(jù)組裝策略，所述數(shù)據(jù)組裝策略用于配置所述業(yè)務(wù)場景的內(nèi)容源數(shù)據(jù)流包括的數(shù)據(jù)內(nèi)容和數(shù)據(jù)類型；

根據(jù)所述數(shù)據(jù)組裝策略獲取所述待處理數(shù)據(jù)流對應(yīng)的待組裝數(shù)據(jù)；

按照所述預(yù)設(shè)數(shù)據(jù)格式組裝所述待組裝數(shù)據(jù)，得到與所述業(yè)務(wù)場景相匹配的目標內(nèi)容源數(shù)據(jù)流。

2.根據(jù)權(quán)利要求1所述的數(shù)據(jù)流處理方法，其特征在于，所述獲取與業(yè)務(wù)場景相匹配的數(shù)據(jù)組裝策略步驟，包括：

獲取與所述業(yè)務(wù)場景相匹配的數(shù)據(jù)組裝配置信息；

解析所述數(shù)據(jù)組裝配置信息得到所述數(shù)據(jù)組裝策略。

3.根據(jù)權(quán)利要求1或2所述的數(shù)據(jù)流處理方法，其特征在于，所述根據(jù)所述數(shù)據(jù)組裝策略獲取所述待處理數(shù)據(jù)流對應(yīng)的待組裝數(shù)據(jù)步驟，包括：

獲取所述數(shù)據(jù)組裝策略包含的數(shù)據(jù)過濾策略，并根據(jù)所述數(shù)據(jù)過濾策略過濾所述待處理數(shù)據(jù)流得到過濾后數(shù)據(jù)流；

獲取所述數(shù)據(jù)組裝策略包含的數(shù)據(jù)注入策略，并根據(jù)所述數(shù)據(jù)注入策略，獲取所述待處理數(shù)據(jù)流對應(yīng)的待注入數(shù)據(jù)，所述待組裝數(shù)據(jù)包括所述過濾后數(shù)據(jù)流和所述待注入數(shù)據(jù)。

4.根據(jù)權(quán)利要求3所述的數(shù)據(jù)流處理方法，其特征在于，所述根據(jù)所述數(shù)據(jù)注入策略，獲取所述待處理數(shù)據(jù)流對應(yīng)的待注入數(shù)據(jù)步驟，包括：

所述數(shù)據(jù)注入策略用于配置所述待處理數(shù)據(jù)流的待注入數(shù)據(jù)的屬性類型，解析所述數(shù)據(jù)注入策略獲得所述待處理數(shù)據(jù)流的待注入數(shù)據(jù)的屬性類型；

從與所述待處理數(shù)據(jù)流對應(yīng)的目標統(tǒng)計數(shù)據(jù)集中，獲取與所述待注入數(shù)據(jù)的屬性類型相匹配的數(shù)據(jù)，所述目標統(tǒng)計數(shù)據(jù)集包括所述內(nèi)容源數(shù)據(jù)在各預(yù)設(shè)統(tǒng)計維度的統(tǒng)計數(shù)據(jù)。

5.根據(jù)權(quán)利要求3所述的數(shù)據(jù)流處理方法，其特征在于，所述根據(jù)所述數(shù)據(jù)注入策略，獲取所述待處理數(shù)據(jù)流對應(yīng)的待注入數(shù)據(jù)步驟，包括：

解析所述數(shù)據(jù)注入策略獲得所述待處理數(shù)據(jù)流對應(yīng)的待注入數(shù)據(jù)的屬性類型；

從業(yè)務(wù)方提供的數(shù)據(jù)中獲取與所述待注入數(shù)據(jù)的屬性類型相匹配的數(shù)據(jù)。

6.根據(jù)權(quán)利要求3所述的數(shù)據(jù)流處理方法，其特征在于，所述根據(jù)所述數(shù)據(jù)過濾策略過濾所述待處理數(shù)據(jù)流得到過濾后數(shù)據(jù)流步驟，包括：

解析所述數(shù)據(jù)過濾策略獲得所述待處理數(shù)據(jù)流中待過濾數(shù)據(jù)的屬性類型；

過濾掉所述待處理數(shù)據(jù)流中與所述待過濾數(shù)據(jù)的屬性類型相匹配的數(shù)據(jù)。

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

數(shù)據(jù)流獲取模塊，被配置為執(zhí)行獲取內(nèi)容源數(shù)據(jù)流；

數(shù)據(jù)格式轉(zhuǎn)換模塊，被配置為執(zhí)行轉(zhuǎn)換所述內(nèi)容源數(shù)據(jù)流的數(shù)據(jù)格式為預(yù)設(shè)數(shù)據(jù)格式得到待處理數(shù)據(jù)流；

組裝策略獲取模塊，被配置為執(zhí)行獲取與業(yè)務(wù)場景相匹配的數(shù)據(jù)組裝策略，所述數(shù)據(jù)組裝策略用于配置所述業(yè)務(wù)場景的內(nèi)容源數(shù)據(jù)流包括的數(shù)據(jù)的屬性類型；

組裝數(shù)據(jù)獲取模塊，被配置為執(zhí)行根據(jù)所述數(shù)據(jù)組裝策略獲取所述待處理數(shù)據(jù)流對應(yīng)的待組裝數(shù)據(jù)；

數(shù)據(jù)組裝模塊，被配置為執(zhí)行按照所述預(yù)設(shè)數(shù)據(jù)格式組裝所述待組裝數(shù)據(jù)，得到與所述業(yè)務(wù)場景相匹配的目標內(nèi)容源數(shù)據(jù)流。

8.一種服務(wù)器，其特征在于，包括：

處理器；

用于存儲所述處理器可執(zhí)行指令的存儲器；

其中，所述處理器被配置為執(zhí)行所述指令，以實現(xiàn)如權(quán)利要求1至6中任一項所述的數(shù)據(jù)流處理方法。

9.一種存儲介質(zhì)，當所述存儲介質(zhì)中的指令由服務(wù)器的處理器執(zhí)行時，使得服務(wù)器能夠執(zhí)行如權(quán)利要求1至6中任一項所述的數(shù)據(jù)流處理方法。

10.一種計算機程序產(chǎn)品，其特征在于，所述計算機程序產(chǎn)品中存儲有指令，當所述指令由服務(wù)器中的處理器執(zhí)行時，實現(xiàn)權(quán)利要求1至6中任一項所述的數(shù)據(jù)流處理方法。