[發明專利]數據流處理方法及裝置

在審

• 申請號: 202110314078.0
• 申請日: 2021-03-24
• 公開（公告）號: CN113065029A
• 公開（公告）日: 2021-07-02
• 發明（設計）人: 程企堯
• 申請（專利權）人: 北京達佳互聯信息技術有限公司
• 主分類號: G06F16/90
• 分類號: G06F16/90;G06F16/70
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 劉猛

本公開關于一種數據流處理方法及裝置，該數據流處理方法在獲得任一業務場景的內容源數據流后，轉換為預設數據格式得到待處理數據流；獲取當前業務場景相匹配的數據組裝策略；根據數據組裝策略獲取該待處理數據流對應的待組裝數據，并按預設數據格式組裝待組裝數據得到與當前業務場景相匹配的目標內容源數據流。該方案將不同業務場景的內容源數據流處理流程進行單元化、組件化，并按照不同業務場景的處理需求對處理單元進行組合，不需要分別針對不同的業務場景開發不同的處理流程，大大降低了開發成本和維護成本。而且，統一處理邏輯框架中的處理流程進行單元化和組件化，以方便擴展內容源數據流處理流程，因此提高了可擴展性。

技術領域

本公開涉及計算機技術領域，尤其涉及數據流處理方法及裝置。

背景技術

數據流是一組順序、大量、快速、連續到達的數據序列，通常數據流可被視為一個隨時間延續而無限增長的動態數據集合。目前很多應用程序(Application，APP)的信息展示均是數據流展示，數據流展示能夠將同一類的數據內容源源不斷地向用戶展示。

不同的業務場景下需要接入不同數據來源的原始數據，而且，不同的業務場景需要對原始數據進行不同的處理，例如，某些業務場景下需要一些地理位置，而另一些業務場景下不需要地理位置。相關技術中，需要分別針對不同業務場景分別開發相應的數據處理邏輯，導致開發成本高、維護成本高、業務擴展性差。

相關技術中，通常是每個展示場景采用針對該場景業務特點的相對獨立的數據處理邏輯進行處理，數據處理流程縱橫交錯，有的模塊獨立支持，有的模塊共用。而且，各個業務各自把幾個獨立處理邏輯拼成一個大的邏輯，造成大量代碼冗余，維護成本高，業務擴展性差。

發明內容

本公開提供一種數據流處理方法及裝置，以至少解決相關技術中不同業務場景對應的數據流處理流程開發成本高、維護成本高、業務擴展性差的問題。本公開的技術方案如下：

根據本公開實施例的第一方面，提供一種數據流處理方法，包括：

獲取內容源數據流；

轉換所述內容源數據流的數據格式為預設數據格式得到待處理數據流；

獲取與業務場景相匹配的數據組裝策略，所述數據組裝策略用于配置所述業務場景的內容源數據流包括的數據內容和數據類型；

根據所述數據組裝策略獲取所述待處理數據流對應的待組裝數據；

按照所述預設數據格式組裝所述待組裝數據，得到與所述業務場景相匹配的目標內容源數據流。

在第一方面一種可能的實現方式中，所述獲取與業務場景相匹配的數據組裝策略步驟，包括：

獲取與所述業務場景相匹配的數據組裝配置信息；

解析所述數據組裝配置信息得到所述數據組裝策略。

在第一方面另一種可能的實現方式中，所述根據所述數據組裝策略獲取所述待處理數據流對應的待組裝數據步驟，包括：

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

獲取所述數據組裝策略包含的數據注入策略，并根據所述數據注入策略，獲取所述待處理數據流對應的待注入數據，所述待組裝數據包括所述過濾后數據流和所述待注入數據。

在第一方面又一種可能的實現方式中，所述根據所述數據注入策略，獲取所述待處理數據流對應的待注入數據步驟，包括：

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