[發明專利]數據處理方法、邊緣節點、數據中心及存儲介質

在審

• 申請號: 202010086244.1
• 申請日: 2020-02-11
• 公開（公告）號: CN111339183A
• 公開（公告）日: 2020-06-26
• 發明（設計）人: 曹智穎
• 申請（專利權）人: 騰訊云計算（北京）有限責任公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F9/50
• 代理公司: 北京派特恩知識產權代理有限公司 11270
• 代理人: 劉暉銘;張穎玲

1.一種數據處理方法，其特征在于，所述方法包括：

從數據源收集待處理的數據流；

對所述數據流中的數據進行處理，得到處理結果；

確定所述數據流中當前已處理且未上報數據作為待上報數據；

當所述待上報數據的數據信息滿足特定的分割閾值時，將數據信息滿足所述分割閾值的待上報數據確定為當前批次數據；

將所述當前批次數據的處理結果上報至數據中心，以使所述數據中心對所述處理結果進行處理，得到所述數據流的目標處理結果。

2.根據權利要求1所述的方法，其特征在于，所述方法還包括:

確定對所述數據流進行數據分析的維度；

根據所述維度，設定批量處理所述數據流中的數據的分割閾值。

3.根據權利要求2所述的方法，其特征在于，所述據所述維度，設定批量處理所述數據流中的數據的分割閾值，包括：

如果所述維度為時間，確定所述數據流所占據的總時長；根據所述總時長，確定用于作為所述分割閾值的時長閾值；

如果所述待上報數據所占據的時長達到所述時長閾值，確定所述待上報數據滿足所述分割閾值。

4.根據權利要求2所述的方法，其特征在于，所述據所述維度，設定批量處理所述數據流中的數據的分割閾值，包括：

如果所述維度為數據量，確定所述數據流所占據總數據量；根據所述總數據量，確定用于作為所述分割閾值的數據量閾值；

如果所述待上報數據的數據量達到所述數據量閾值，確定所述待上報數據滿足所述分割閾值。

5.根據權利要求1所述的方法，其特征在于，在所述確定所述數據流中待上報數據作為待上報數據之后，所述方法還包括：

如果所述待上報數據的數據信息未滿足所述分割閾值，繼續從所述數據源收集所述數據流中的數據；

對繼續收集到的數據進行處理，當待上報數據的數據信息滿足所述分割閾值時，將滿足所述分割閾值的待上報數據的處理結果上報至所述數據中心。

6.根據權利要求4所述的方法，其特征在于，在所述當待上報數據的數據信息滿足所述分割閾值時，將滿足所述分割閾值的待上報數據的處理結果上報至所述數據中心之前，所述方法還包括：

如果所述待上報數據的數據信息未滿足所述分割閾值，將待上報數據的處理結果存儲在本地內存中；

當待上報數據的數據信息滿足所述分割閾值時，從所述本地內存中，提取滿足所述分割閾值的待上報數據的處理結果，上報至所述數據中心。

7.根據權利要求1至6任一項所述的方法，其特征在于，在所述將所述當前批次數據的處理結果上報至數據中心，以使所述數據中心對所述處理結果進行處理，得到所述數據流的目標處理結果之后，所述方法還包括：

清除當前已上報處理結果的數據和所述當前已上報處理結果；

從所述數據源收集所述數據流中的未處理的下一批次數據；

對所述下一批次數據進行處理，當所述下一批次數據的數據信息滿足所述分割閾值時，將所述下一批次數據的處理結果上報至所述數據中心。

8.一種數據處理方法，其特征在于，所述方法包括：

接收邊緣節點上傳的待處理的數據流中多批次數據的處理結果；其中，每一批次數據的數據信息均滿足分割閾值；

確定所述數據流的待實現的功能；

根據所述待實現的功能，對所述多批次數據的處理結果進行處理，得到所述數據流的目標處理結果。

9.根據權利要求8所述的方法，其特征在于，所述根據所述待實現的功能，對所述多批次數據的處理結果進行處理，得到所述數據流的目標處理結果，包括：

如果所述待實現的功能為對所述數據流進行篩選，確定篩選條件；

從所述多批次數據的處理結果中，選擇滿足所述篩選條件的目標處理結果。