[發(fā)明專利]基于數(shù)據(jù)同步的壓測(cè)方法、裝置、計(jì)算機(jī)設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202011504827.8
• 申請(qǐng)日: 2020-12-18
• 公開（公告）號(hào): CN112631884A
• 公開（公告）日: 2021-04-09
• 發(fā)明（設(shè)計(jì)）人: 丁勇
• 申請(qǐng)（專利權(quán)）人: 平安普惠企業(yè)管理有限公司
• 主分類號(hào): G06F11/34
• 分類號(hào): G06F11/34;G06F16/27
• 代理公司: 深圳市世聯(lián)合知識(shí)產(chǎn)權(quán)代理有限公司 44385
• 代理人: 汪琳琳

1.一種基于數(shù)據(jù)同步的壓測(cè)方法，其中，基于數(shù)據(jù)同步的壓測(cè)方法應(yīng)用于kafka集群的壓力測(cè)試系統(tǒng)，所述kafka集群的壓力測(cè)試系統(tǒng)包括源數(shù)據(jù)庫、kafka集群和OGG鏈路，所述OGG鏈路用于連接所述源數(shù)據(jù)庫和所述kafka集群，其特征在于，還包括造數(shù)平臺(tái)，基于數(shù)據(jù)同步的壓測(cè)方法具體包括：

接收用戶輸入的壓力測(cè)試請(qǐng)求，其中，所述壓力測(cè)試請(qǐng)求包含模板數(shù)據(jù)、測(cè)試數(shù)據(jù)生成條件和測(cè)試指令；

發(fā)送所述模板數(shù)據(jù)至所述源數(shù)據(jù)庫，遍歷存儲(chǔ)在所述源數(shù)據(jù)庫中的歷史數(shù)據(jù)，判斷所述源數(shù)據(jù)庫中是否存在與所述模板數(shù)據(jù)相匹配的歷史數(shù)據(jù)；

若存在，則發(fā)送所述模板數(shù)據(jù)和測(cè)試數(shù)據(jù)生成條件至所述造數(shù)平臺(tái)，并指示所述造數(shù)平臺(tái)基于所述模板數(shù)據(jù)和測(cè)試數(shù)據(jù)生成條件生成測(cè)試數(shù)據(jù)；

發(fā)送所述測(cè)試指令和所述測(cè)試數(shù)據(jù)至所述kafka集群，并指示所述kafka集群根據(jù)所述測(cè)試指令和所述測(cè)試數(shù)據(jù)進(jìn)行壓力測(cè)試，生成測(cè)試結(jié)果。

2.如權(quán)利要求1所述的基于數(shù)據(jù)同步的壓測(cè)方法，其特征在于，所述發(fā)送所述模板數(shù)據(jù)至所述源數(shù)據(jù)庫，遍歷存儲(chǔ)在所述源數(shù)據(jù)庫中的歷史數(shù)據(jù)，判斷所述源數(shù)據(jù)庫中是否存在與所述模板數(shù)據(jù)相匹配的歷史數(shù)據(jù)的步驟，具體包括：

對(duì)所述模板數(shù)據(jù)進(jìn)行解析，獲取所述模板數(shù)據(jù)的格式信息；

遍歷存儲(chǔ)在所述源數(shù)據(jù)庫中的歷史數(shù)據(jù)，基于所述模板數(shù)據(jù)的格式信息，對(duì)所述模板數(shù)據(jù)與存儲(chǔ)在所述源數(shù)據(jù)庫中的所有歷史數(shù)據(jù)進(jìn)行格式比對(duì)；

根據(jù)比對(duì)結(jié)果判斷所述源數(shù)據(jù)庫中是否存在與所述模板數(shù)據(jù)相匹配的歷史數(shù)據(jù)。

3.如權(quán)利要求2所述的基于數(shù)據(jù)同步的壓測(cè)方法，其特征在于，在所述根據(jù)比對(duì)結(jié)果判斷所述源數(shù)據(jù)庫中是否存在與所述模板數(shù)據(jù)相匹配的歷史數(shù)據(jù)之后，還包括：

若在所述源數(shù)據(jù)庫中不存在與所述模板數(shù)據(jù)的格式完全一致歷史數(shù)據(jù)，則計(jì)算所述模板數(shù)據(jù)與存儲(chǔ)在所述源數(shù)據(jù)庫中的所有歷史數(shù)據(jù)的相似度；

對(duì)計(jì)算得到的相似度進(jìn)行排序，并輸出相似度排序結(jié)果的最大值對(duì)應(yīng)的歷史數(shù)據(jù)。

4.如權(quán)利要求1所述的基于數(shù)據(jù)同步的壓測(cè)方法，其特征在于，所述發(fā)送所述模板數(shù)據(jù)和測(cè)試數(shù)據(jù)生成條件至所述造數(shù)平臺(tái)，并指示所述造數(shù)平臺(tái)基于所述模板數(shù)據(jù)和測(cè)試數(shù)據(jù)生成條件生成測(cè)試數(shù)據(jù)的的步驟，具體包括：

將所述模板數(shù)據(jù)和所述測(cè)試數(shù)據(jù)生成條件發(fā)送至所述造數(shù)平臺(tái)；

指示所述造數(shù)平臺(tái)獲取所述測(cè)試數(shù)據(jù)生成條件中的字段標(biāo)識(shí)，并指示所述造數(shù)平臺(tái)基于所述字段標(biāo)識(shí)確定所述模板數(shù)據(jù)的可變字段；

指示所述造數(shù)平臺(tái)對(duì)所述可變字段中的各個(gè)字節(jié)進(jìn)行隨機(jī)填充，得到測(cè)試數(shù)據(jù)。

5.如權(quán)利要求1至4任意一項(xiàng)所述的基于數(shù)據(jù)同步的壓測(cè)方法，其特征在于，所述發(fā)送所述測(cè)試指令和所述測(cè)試數(shù)據(jù)至所述kafka集群的步驟，具體包括：

對(duì)所述測(cè)試數(shù)據(jù)進(jìn)行格式轉(zhuǎn)換，得到bytes類型的測(cè)試數(shù)據(jù)；

調(diào)用所述kafka集群自帶的消息生產(chǎn)者，并指示所述消息生產(chǎn)者將所述bytes類型的測(cè)試數(shù)據(jù)寫入到所述kafka集群的消費(fèi)主題中。

6.如權(quán)利要求1所述的基于數(shù)據(jù)同步的壓測(cè)方法，其特征在于，所述指示所述kafka集群根據(jù)所述測(cè)試指令和所述測(cè)試數(shù)據(jù)進(jìn)行壓力測(cè)試，生成測(cè)試結(jié)果的步驟，具體包括：

指示所述kafka集群基于所述測(cè)試指令調(diào)用預(yù)設(shè)的壓力測(cè)試腳本；

指示所述kafka集群將所述測(cè)試數(shù)據(jù)導(dǎo)入到所述預(yù)設(shè)的壓力測(cè)試腳本中，獲取所述壓力測(cè)試腳本的輸出，得到所述kafka集群的壓力測(cè)試結(jié)果。

7.如權(quán)利要求1所述的基于數(shù)據(jù)同步的壓測(cè)方法，其特征在于，還包括：

將所述用戶輸入的壓力測(cè)試請(qǐng)求存儲(chǔ)至區(qū)塊鏈中。