[發(fā)明專利]一種指標(biāo)數(shù)據(jù)獲取方法、裝置、電子設(shè)備和存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202110705948.7
• 申請日: 2021-06-24
• 公開（公告）號: CN113448752A
• 公開（公告）日: 2021-09-28
• 發(fā)明（設(shè)計）人: 魯友炳;俞舒;吳迪;張鎮(zhèn)潮;施建生
• 申請（專利權(quán)）人: 億企贏網(wǎng)絡(luò)科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F16/2455
• 代理公司: 北京集佳知識產(chǎn)權(quán)代理有限公司 11227
• 代理人: 豆貝貝

1.一種指標(biāo)數(shù)據(jù)獲取方法，其特征在于，包括：

接收業(yè)務(wù)方發(fā)送的指標(biāo)配置創(chuàng)建請求，并根據(jù)所述指標(biāo)配置創(chuàng)建請求，生成控制流命令消息；

將所述控制流命令消息發(fā)送至kafka消息隊列，以使所述kafka消息隊列廣播所述控制流命令消息至flink算子；

當(dāng)接收到事件流消息時，將所述事件流消息發(fā)送至所述kafka消息隊列，以使所述flink算子消費(fèi)所述事件流消息；

利用所述flink算子對所述事件流消息進(jìn)行指標(biāo)計算，確定指標(biāo)數(shù)據(jù)。

2.根據(jù)權(quán)利要求1所述的指標(biāo)數(shù)據(jù)獲取方法，其特征在于，所述利用所述flink算子對所述事件流消息進(jìn)行指標(biāo)計算，包括：

根據(jù)所述控制流命令消息對應(yīng)的指標(biāo)規(guī)則的標(biāo)識碼和所述事件流消息的事件ID，生成事件分區(qū)key；

將所述事件流消息分配至所述事件分區(qū)key對應(yīng)的目標(biāo)分區(qū)；

在所述目標(biāo)分區(qū)中，利用所述flink算子對所述事件流消息進(jìn)行指標(biāo)計算。

3.根據(jù)權(quán)利要求1所述的指標(biāo)數(shù)據(jù)獲取方法，其特征在于，在所述將所述控制流命令消息發(fā)送至kafka消息隊列，以使所述kafka消息隊列廣播所述控制流命令消息至flink算子之后，還包括：

將所述控制流命令消息對應(yīng)的指標(biāo)規(guī)則存儲至分布式文件存儲系統(tǒng)，以使所述控制流命令消息對應(yīng)的指標(biāo)規(guī)則狀態(tài)持久化。

4.根據(jù)權(quán)利要求1所述的指標(biāo)獲取方法，其特征在于，在所述確定指標(biāo)數(shù)據(jù)之后，還包括：

將所述指標(biāo)數(shù)據(jù)推送至目標(biāo)數(shù)據(jù)庫，以存儲所述指標(biāo)數(shù)據(jù)。

5.根據(jù)權(quán)利要求1至4任一項所述的指標(biāo)獲取方法，其特征在于，還包括：

當(dāng)接收到指標(biāo)規(guī)則變更消息時，根據(jù)所述指標(biāo)規(guī)則變更消息，生成更新后的控制流命令消息；

將所述更新后的控制流命令消息發(fā)送至所述kafka消息隊列，以使所述flink算子消費(fèi)所述kafka消息隊列廣播的所述更新后的控制流命令消息更新當(dāng)前指標(biāo)規(guī)則。

6.一種指標(biāo)數(shù)據(jù)獲取裝置，其特征在于，包括：

接收模塊，用于接收業(yè)務(wù)方發(fā)送的指標(biāo)配置創(chuàng)建請求，并根據(jù)所述指標(biāo)配置創(chuàng)建請求，生成控制流命令消息；

第一發(fā)送模塊，用于將所述控制流命令消息發(fā)送至kafka消息隊列，以使所述kafka消息隊列廣播所述控制流命令消息至flink算子；

第二發(fā)送模塊，用于當(dāng)接收到事件流消息時，將所述事件流消息發(fā)送至所述kafka消息隊列，以使所述flink算子消費(fèi)所述事件流消息；

確定模塊，用于利用所述flink算子對所述事件流消息進(jìn)行指標(biāo)計算，確定指標(biāo)數(shù)據(jù)。

7.根據(jù)權(quán)利要求6所述的指標(biāo)數(shù)據(jù)獲取裝置，其特征在于，所述確定模塊，包括：

生成單元，用于根據(jù)所述控制流命令消息對應(yīng)的指標(biāo)規(guī)則的標(biāo)識碼和所述事件流消息的事件ID，生成事件分區(qū)key；

分配單元，用于將所述事件流消息分配至所述事件分區(qū)key對應(yīng)的目標(biāo)分區(qū)；

計算單元，用于在所述目標(biāo)分區(qū)中，利用所述flink算子對所述事件流消息進(jìn)行指標(biāo)計算。

8.根據(jù)權(quán)利要求6所述的指標(biāo)數(shù)據(jù)獲取裝置，其特征在于，還包括：

存儲模塊，用于將所述控制流命令消息對應(yīng)的指標(biāo)規(guī)則存儲至分布式文件存儲系統(tǒng)，以使所述控制流命令消息對應(yīng)的指標(biāo)規(guī)則狀態(tài)持久化。

9.一種電子設(shè)備，其特征在于，包括：

存儲器，用于存儲計算機(jī)程序；

處理器，用于執(zhí)行所述計算機(jī)程序時實(shí)現(xiàn)如權(quán)利要求1至5任一項所述指標(biāo)數(shù)據(jù)獲取方法的步驟。

10.一種存儲介質(zhì)，其特征在于，所述存儲介質(zhì)上存儲有計算機(jī)程序，所述計算機(jī)程序被處理器執(zhí)行時實(shí)現(xiàn)如權(quán)利要求1至5任一項所述指標(biāo)數(shù)據(jù)獲取方法的步驟。