[發明專利]用于數據處理系統的數據模塊管理

有效

• 申請號: 201910122751.3
• 申請日: 2019-02-19
• 公開（公告）號: CN110244994B
• 公開（公告）日: 2022-08-09
• 發明（設計）人: D·G·貝里尼;D·里佐;S·米拉戈利亞
• 申請（專利權）人: 埃森哲環球解決方案有限公司
• 主分類號: G06F9/451
• 分類號: G06F9/451
• 代理公司: 北京市金杜律師事務所 11256
• 代理人: 酆迅

1.一種用于數據處理的設備，包括：

一個或者多個存儲器設備；以及

一個或者多個處理器，所述一個或者多個處理器被通信地連接至所述一個或者多個存儲器設備，并且被配置為：

從網絡數據源接收數據；

標識被包括在接收的所述數據中的屬性，其中當標識被包括在接收的所述數據中的所述屬性時，所述一個或者多個處理器被配置為用于基于先前由所述網絡數據源提供至所述設備的其他信息來標識被包括在接收的所述數據中的所述屬性；

向用戶設備提供用戶界面，所述用戶界面提供用戶界面元素，所述用戶界面元素通過與所述用戶界面元素中的一個或者多個用戶界面元素的交互并且通過對以下項目中的至少一項進行選擇或修改，以創建更新的數據模塊：

所述屬性中的至少一個屬性，

要由數據處理流水線執行的至少一個功能，所述數據處理流水線與所述更新的數據模塊分離，

與所述至少一個屬性的屬性相關聯的至少一個條件，

與所述至少一個功能的執行相關聯的至少一個時間窗口；

基于所述選擇或修改中的至少一個，通過確定所述更新的數據模塊的語法是否準確來驗證所述更新的數據模塊，所述語法指定所述至少一個屬性、所述至少一個功能或所述至少一個條件中的一項或多項；

基于與所述一個或者多個用戶界面元素中的至少一個用戶界面元素的用戶交互，從所述用戶設備接收標識所述更新的數據模塊的信息，所述更新的數據模塊：

包括所述屬性，

限定所述至少一個條件的條件，并且

限定要由所述數據處理流水線基于所述至少一個時間窗口執行的所述至少一個功能的功能；

將所述更新的數據模塊存儲在隊列中；

基于所述更新的數據模塊被存儲在所述隊列中，激活所述更新的數據模塊以供由所述設備實施的所述數據處理流水線使用；

對傳入的數據進行解析，以標識所述傳入的數據中的屬性；

基于對所述傳入的數據中的屬性的標識，將所述傳入的數據映射至所述更新的數據模塊；以及

基于所述傳入的數據至所述更新的數據模塊的映射，使用所述數據處理流水線和所述更新的數據模塊來對所述傳入的數據執行動作，所述動作包括在所述至少一個時間窗口的時間窗口期間對所述傳入的數據執行所述功能。

2.根據權利要求1所述的設備，其中接收的所述數據包括文本的至少一個字符串。

3.根據權利要求1所述的設備，其中：

所述網絡數據源是流數據的源，并且

接收的所述數據被流傳輸至所述設備。

4.根據權利要求1所述的設備，其中：

所述網絡數據源是批數據的源，并且

接收的所述數據作為一批數據而被接收，

所述一批數據包括多個數據記錄。

5.根據權利要求1所述的設備，其中當標識被包括在接收的所述數據中的所述屬性時，所述一個或者多個處理器被配置為：

基于被包括在接收的所述數據中的元數據來標識被包括在接收的所述數據中的所述屬性。

6.根據權利要求1所述的設備，其中當標識被包括在接收的所述數據中的所述屬性時，所述一個或者多個處理器被配置為：

基于對接收的所述數據執行的分析的結果來標識被包括在接收的所述數據中的所述屬性。

7.根據權利要求1所述的設備，其中所述一個或者多個處理器還被配置為：

基于所述更新的數據模塊被配置為處理所述屬性中的一個屬性來將所述屬性中的所述一個屬性映射至所述更新的數據模塊。

8.根據權利要求1所述的設備，其中當將所述傳入的數據映射至所述更新的數據模塊時，所述一個或者多個處理器被配置為：

確定所述傳入的數據中標識的屬性與所述更新的數據模塊中包括的屬性相匹配。