[發明專利]一種性能測試方法及裝置

在審

• 申請號: 201911365674.0
• 申請日: 2019-12-26
• 公開（公告）號: CN111143143A
• 公開（公告）日: 2020-05-12
• 發明（設計）人: 龍春竹;朱海涅;徐越;劉燕
• 申請（專利權）人: 北京神州綠盟信息安全科技股份有限公司;北京神州綠盟科技有限公司
• 主分類號: G06F11/22
• 分類號: G06F11/22;G06F11/36;G06F9/50
• 代理公司: 北京同達信恒知識產權代理有限公司 11291
• 代理人: 姚曉雨

本發明公開了一種性能測試方法及裝置，其中，方法包括：獲取待測試系統的初始參數；將初始參數輸入至預設算法中，得到性能參數；將性能參數作為測試參數，對待測試系統進行性能測試；若確定待測試系統未通過性能測試，則調整初始參數，直至確定待測試系統通過性能測試。該技術方案用以對基于Flink框架構建的業務系統進行性能測試。

技術領域

本發明實施例涉及測試領域，尤其涉及一種性能測試方法及裝置。

背景技術

Flink核心是一個流式的數據流處理引擎，其針對數據流的分布式引擎提供了數據分析、數據通信以及容錯機制等功能。在實際業務場景適用中，包括實時分析，連續數據管道處理、歷史數據處理和迭代算法(機器學習、圖計算)等數據分析場景；通過結合Time、Window、Trigger等多種處理機制，Flink提供了高性能、低延遲、高容錯且功能強大的流式處理服務。

現有技術中，主要提供對Flink框架本身的基準測試，如基準測試工具HiBench、streaming-benchmarks等，主要側重于對Flink框架本身的單元業務進行單獨測試。基準測試工具不能對基于Flink框架構建的業務系統進行性能測試。

發明內容

本發明實施例提供一種性能測試方法及裝置，用以對基于Flink框架構建的業務系統進行性能測試。

本發明實施例提供的一種性能測試方法，包括：

獲取待測試系統的初始參數；

將所述初始參數輸入至預設算法中，得到性能參數；所述預設算法是根據已有業務系統在歷史測試用例下確定的初始參數和性能參數之間的運算關系；

將所述性能參數作為測試參數，對所述待測試系統進行性能測試；若確定所述待測試系統未通過所述性能測試，則調整所述初始參數，直至確定所述待測試系統通過所述性能測試。

可選的，所述初始參數包括輸入數據量和任務管理器中任務槽個數；

所述性能參數至少包括所述任務管理器的個數、所述任務管理器的內存、所述任務管理器中任務槽個數、線程并行數、作業管理器的內存；

所述將所述初始參數輸入至預設算法中，得到性能參數，包括：

根據所述輸入數據量和單線程的預設數據處理速度，確定所述線程并行數；

根據所述輸入數據量和單線程所占的預設內存，確定所述任務管理器的內存；

根據所述線程并行數、所述任務槽個數，確定所述任務管理器的個數；

根據所述任務管理器的個數、所述任務管理器的內存確定所述作業管理器的內存。

可選的，所述根據所述輸入數據量和單線程的預設數據處理速度，確定所述線程并行數，包括：

根據公式(1)確定所述線程并行數；

所述公式(1)為：

P為線程并行數；X為輸入數據量；S為單線程的預設數據處理速度。

可選的，所述根據所述線程并行數、所述任務槽個數，確定所述任務管理器的個數，包括：

根據公式(2)確定所述任務管理器的個數；

所述公式(2)為：

N_{任務管理器}為任務管理器的個數；P為線程并行數；N_任務槽為任務管理器中任務槽個數。

可選的，所述根據所述任務管理器的個數、所述任務管理器的內存確定所述作業管理器的內存，包括：