[發(fā)明專利]流式計算作業(yè)處理方法、流式計算系統(tǒng)及電子設備

有效

• 申請?zhí)枺?/td>: 202010074558.X
• 申請日: 2020-01-22
• 公開（公告）號: CN111290744B
• 公開（公告）日: 2023-07-21
• 發(fā)明（設計）人: 袁尤軍
• 申請（專利權）人: 北京百度網訊科技有限公司
• 主分類號: G06F8/30
• 分類號: G06F8/30;G06F8/41;G06F9/54
• 代理公司: 北京銀龍知識產權代理有限公司 11243
• 代理人: 許靜;黃燦

1.一種流式計算作業(yè)處理方法，其特征在于，所述方法包括：

獲取流式計算作業(yè)；

以進程方式運行所述流式計算作業(yè)，所述流式計算作業(yè)包括至少一個進程；

所述流式計算作業(yè)包括多個進程；

所述以進程方式運行所述流式計算作業(yè)，包括：

為所述流式計算作業(yè)的不同進程分別分配對應的運行資源；

在所述多個進程的運行資源下分別運行對應的進程，所述多個進程之間相互通信。

2.根據(jù)權利要求1所述的方法，其特征在于，在所述獲取流式計算作業(yè)之前，所述方法還包括：

接收云端服務器發(fā)送的流式計算作業(yè)，所述流式計算作業(yè)由所述云端服務器生成。

3.根據(jù)權利要求1所述的方法，其特征在于，所述以進程方式運行所述流式計算作業(yè)，包括：

以編譯型語言作為實現(xiàn)語言，以進程方式運行所述流式計算作業(yè)。

4.根據(jù)權利要求3所述的方法，其特征在于，所述編譯型語言包括Golang語言。

5.根據(jù)權利要求1所述的方法，其特征在于，所述多個進程之間基于進程間通信IPC相互通信。

6.一種流式計算系統(tǒng)，其特征在于，所述系統(tǒng)包括：

獲取模塊，用于獲取流式計算作業(yè)；

運行模塊，用于以進程方式運行所述流式計算作業(yè)，所述流式計算作業(yè)包括至少一個進程；

所述流式計算作業(yè)包括多個進程；所述運行模塊包括：

分配單元，用于為所述流式計算作業(yè)的不同進程分別分配對應的運行資源；

運行單元，用于在所述多個進程的運行資源下分別運行對應的進程，所述多個進程之間相互通信。

7.根據(jù)權利要求6所述的系統(tǒng)，其特征在于，所述系統(tǒng)還包括：

接收模塊，用于接收云端服務器發(fā)送的流式計算作業(yè)，所述流式計算作業(yè)由所述云端服務器生成。

8.根據(jù)權利要求6所述的系統(tǒng)，其特征在于，所述運行模塊具體用于：

以編譯型語言作為實現(xiàn)語言，以進程方式運行所述流式計算作業(yè)。

9.根據(jù)權利要求8所述的系統(tǒng)，其特征在于，所述編譯型語言包括Golang語言。

10.根據(jù)權利要求6所述的系統(tǒng)，其特征在于，所述多個進程之間基于進程間通信IPC相互通信。

11.一種電子設備，其特征在于，包括：

至少一個處理器；以及

與所述至少一個處理器通信連接的存儲器；其中，

所述存儲器存儲有可被所述至少一個處理器執(zhí)行的指令，所述指令被所述至少一個處理器執(zhí)行，以使所述至少一個處理器能夠執(zhí)行權利要求1至5中任一項所述的方法。

12.一種存儲有計算機指令的非瞬時計算機可讀存儲介質，其特征在于，所述計算機指令用于使所述計算機執(zhí)行權利要求1至5中任一項所述的方法。