[發明專利]物聯網中的數據分析任務創建方法、裝置及存儲介質

有效

• 申請號: 201911405989.3
• 申請日: 2019-12-31
• 公開（公告）號: CN111552470B
• 公開（公告）日: 2023-09-12
• 發明（設計）人: 何嘉慶;許景楠;鄭伊翎;趙宏
• 申請（專利權）人: 遠景智能國際私人投資有限公司;上海遠景科創智能科技有限公司
• 主分類號: G06F8/38
• 分類號: G06F8/38;G16Y10/75
• 代理公司: 北京三高永信知識產權代理有限責任公司 11138
• 代理人: 寧立存

1.一種物聯網中的數據分析任務創建方法，其特征在于，所述方法包括：

顯示可視化的數據分析任務的創建界面，所述創建界面上顯示有算子備選區以及算子編輯區，所述算子備選區提供有n種數據處理算子，n為正整數，所述數據處理算子用于按照對應的處理邏輯對輸入的數據進行處理，其中，所述數據是能源類物聯網設備輸入的數據，所述數據分析任務用于處理物聯網中的流數據，所述算子備選區中的所述數據處理算子是根據物聯網場景設計的算子，所述數據處理算子包括資產主數據算子、數據計算算子、數據質量算子、電量計算算子、具有建立數據源功能的數據源算子、具有建立目標源功能的目標源算子、普適性算子以及特定任務算子中的至少一種，所述普適性算子是從物聯網中各領域中抽取并封裝的各種計算任務中共同的、普適的計算邏輯，所述普適性算子用以處理所述數據分析任務中普遍適用于同類型計算的算子，所述特定任務算子是根據物聯網場景中的計算任務所設計的定制算子，所述特定任務算子用以處理所述數據分析任務中針對特定類型計算的算子，所述特定任務算子包括增量計算算子、站點聚合器算子中的至少一種，所述算子用于能源類物聯網場景的業務計算；

響應于接收到基于所述算子編輯區對至少兩個目標數據處理算子的用戶操作，根據所述用戶操作對各個所述目標數據處理算子進行編輯，得到各個所述目標數據處理算子的執行順序和執行參數，所述目標數據處理算子是所述n種數據處理算子中被選擇的數據處理算子；

根據各個所述目標數據處理算子的執行順序和執行參數生成數據分析任務，所述數據分析任務由包含輸入數據的數據源算子、包含輸出數據的目標源算子和所述數據處理器所構成，所述數據處理器由所述目標數據處理算子構成，所述目標源用于將所述數據處理器處理完成后的數據存入目標系統；其中，所述目標系統是支持存儲實時計算的中間狀態和計算結果的數據庫。

2.根據權利要求1所述的方法，其特征在于，所述算子編輯區包括算子組合區和參數編輯區，所述參數編輯區中提供有算子參數設置控件；

所述響應于接收到基于所述算子編輯區對至少兩個目標數據處理算子的用戶操作，根據所述用戶操作對所述目標數據處理算子進行編輯，得到各個所述目標數據處理算子的執行順序和執行參數，包括：

在接收到基于所述算子組合區對各個所述目標數據處理算子的順序編排操作后，根據各個所述目標數據處理算子在所述算子組合區中的連接關系，得到各個所述目標數據處理算子的執行順序；

在接收到基于所述參數編輯區對各個所述目標數據處理算子的參數設置操作后，根據所述參數設置操作對各個所述目標數據處理算子進行參數設置，得到所述各個所述目標數據處理算子的執行參數。

3.根據權利要求2所述的方法，其特征在于，所述順序編排操作包括選擇操作、移動操作以及刪除操作中的至少一種；所述方法還包括：

響應于接收到基于所述算子組合區對所述目標數據處理算子的選擇操作，根據所述選擇操作在所述算子組合區中的所述數據分析任務中增加所述目標數據處理算子；

響應于接收到基于所述算子組合區對所述目標數據處理算子的移動操作，根據所述移動操作在所述算子組合區中的所述數據分析任務中移動所述目標數據處理算子的位置；

響應于接收到基于所述算子組合區對所述目標數據處理算子的刪除操作，根據所述刪除操作在所述算子組合區中的所述數據分析任務中刪除所述目標數據處理算子。

4.根據權利要求1所述的方法，其特征在于，所述創建界面中還包括校驗控件；

所述方法還包括：

響應于接收到基于所述校驗控件的校驗操作，根據預先設置的數據分析任務合法性校驗規則對所述數據分析任務進行合法性校驗；

其中，所述合法性校驗包括對所述數據分析任務中各個數據處理算子的執行參數進行合法性校驗，以及，對所述數據分析任務中各個數據處理算子之間的組合搭配進行合法性校驗中的至少一種。

5.根據權利要求1所述的方法，其特征在于，所述創建界面中還包括預覽控件；

所述方法還包括：

接收預覽配置信息，所述預覽配置信息用于驗證所述數據分析任務的輸入數據和輸出數據是否正常；

響應于接收到基于所述預覽控件的預覽操作，基于所述預覽配置信息運行所述數據分析任務。