[發明專利]一種數據流處理方法、服務器及計算機存儲介質

有效

• 申請號: 201910656452.8
• 申請日: 2019-07-19
• 公開（公告）號: CN110505278B
• 公開（公告）日: 2021-09-14
• 發明（設計）人: 許仕霖
• 申請（專利權）人: 聯想（北京）有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京派特恩知識產權代理有限公司 11270
• 代理人: 李梅香;張穎玲

1.一種數據流處理方法，所述方法包括：

獲取數據集群中每個設備的配置信息；其中，所述配置信息包括應用軟件信息；

獲取待處理的第一數據流的屬性信息；

基于每個設備的所述配置信息和所述第一數據流的屬性信息，從所述數據集群的設備中確定目標設備；

控制所述目標設備對所述第一數據流進行處理；

其中，所述基于每個設備的所述配置信息和所述第一數據流的屬性信息，從所述數據集群的設備中確定目標設備，包括：

基于所述第一數據流的屬性信息、所述應用軟件信息以及所述每個設備的屬性參數，從所述數據集群的設備中確定第二設備；

從所述第二設備中確定出處理所述第一數據流所需時間最短的設備為所述目標設備。

2.根據權利要求1所述的方法，其特征在于，所述獲取待處理的第一數據流的屬性信息，包括：

獲取待處理數據的第一數據流的數據類型信息；

相應的，基于每個設備的所述配置信息和所述第一數據流的屬性信息，從所述數據集群的設備中確定目標設備，包括：

基于所述第一數據流的類型信息和所述每個設備的所述配置信息，從所述數據集群的設備中確定所述目標設備。

3.根據權利要求2所述的方法，其特征在于，所述獲取數據集群中每個設備的配置信息，包括：

獲取所述數據集群中每個設備的應用軟件信息；

相應的，所述基于所述第一數據流的類型信息和所述每個設備的所述配置信息，從所述數據集群的設備中確定所述目標設備，包括：

基于所述第一數據流的類型信息和所述應用軟件信息，從所述數據集群的設備中確定所述目標設備。

4.根據權利要求3所述的方法，其特征在于，所述基于所述第一數據流的類型信息和所述應用軟件信息，從所述數據集群的設備中確定所述目標設備，包括：

獲取所述數據集群中每個設備的屬性參數；

基于所述第一數據流的類型信息、所述應用軟件信息以及所述每個設備的屬性參數，從所述數據集群的設備中確定所述目標設備。

5.根據權利要求4所述的方法，其特征在于，所述基于所述第一數據流的類型信息、所述應用軟件信息以及所述每個設備的屬性參數，從所述數據集群的設備中確定所述目標設備，包括：

基于每個設備的屬性參數，從所述數據集群中確定設備的屬性參數滿足預設參數的第一設備；

基于所述第一數據流的類型信息和所述應用軟件信息，從所述第一設備中確定所述目標設備。

6.根據權利要求4或5所述的方法，其特征在于，所述基于所述第一數據流的類型信息、所述應用軟件信息以及所述每個設備的屬性參數，從所述數據集群的設備中確定所述目標設備，包括：

基于所述第一數據流的類型信息、所述應用軟件信息以及所述每個設備的屬性參數，從所述數據集群的設備中確定第二設備；

獲取所述每一第二設備處理所述第一數據流的第一時間；其中，所述第一時間包括所述第一數據流產生時間、所述每一第二設備讀寫所述第一數據流的時間、所述第一數據流暫存到所述每一第二設備磁盤的時間以及所述第一數據流網絡傳輸的時間；

基于所述第一時間計算第二時間；

基于所述第二時間，從所述第二設備中確定所述目標設備。

7.根據權利要求6所述的方法，其特征在于，所述基于所述第一時間計算第二時間，包括：

若所述第一時間滿足預設時間閾值，對所述每一所述第二設備對應的第一時間求和，得到多個第三時間；

按照從小到大的順序對所述多個第三時間進行排序，并從排序后的第三時間中確定最短的時間為所述第二時間。