[發明專利]用于數據流系統的壓力測試方法和裝置

在審

• 申請號: 201710425004.8
• 申請日: 2017-06-06
• 公開（公告）號: CN109002385A
• 公開（公告）日: 2018-12-14
• 發明（設計）人: 雷強;劉業輝;王彥明
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F11/34
• 分類號: G06F11/34
• 代理公司: 北京英賽嘉華知識產權代理有限責任公司 11204
• 代理人: 王達佐;馬曉亞

1.一種用于數據流系統的壓力測試方法，其特征在于，所述數據流系統包括用于對數據流進行處理的數據流處理節點集合，所述數據流從數據流處理節點集合中的、作為入口的數據流處理節點流入并在流經數據流處理節點集合中的至少一個數據流處理節點之后流出所述數據流系統，所述方法包括：

響應于接收到壓力測試指令，對待處理數據流進行解析，生成壓力測試數據流；

將所述待處理數據流和所述壓力測試數據流從所述作為入口的數據流處理節點輸入至所述數據流系統；

周期性地確定所述數據流系統處理所輸入的數據流中的數據的延遲時間，并基于所確定的延遲時間，確定壓力測試是否通過。

2.根據權利要求1所述的方法，其特征在于，所述響應于接收到壓力測試指令，對待處理數據流進行解析，生成壓力測試數據流，包括：

響應于接收到壓力測試指令，提取與所述待處理數據流中的每一個待處理數據相匹配的屬性信息，其中，屬性信息包括日期、客戶端標識和用戶標識；

基于所提取的屬性信息，生成壓力測試數據流。

3.根據權利要求2所述的方法，其特征在于，所述基于所提取的屬性信息，生成壓力測試數據流，包括：

對于所述待處理數據流中的每一個待處理數據，對所提取的與該待處理數據相匹配的屬性信息進行多次更改，以生成數量為第一預設數量的壓力測試數據，并將所生成的壓力測試數據匯總為壓力測試數據流。

4.根據權利要求2所述的方法，其特征在于，所述基于所提取的屬性信息，生成壓力測試數據流，包括：

確定所述待處理數據流中的、預設時長內的待處理數據的數量，將所確定的數量作為第一數量，確定第二預設數量與所述第一數量的差值；

將所述差值與所述第一數量的比值確定為第二數量，對于所述待處理數據流中的每一個待處理數據，對所提取的與該待處理數據相匹配的屬性信息進行多次更改，以生成數量為所述第二數量的壓力測試數據，并將所生成的壓力測試數據匯總為壓力測試數據流。

5.根據權利要求1所述的方法，其特征在于，所述作為入口的數據流處理節點包括作為入口的第一數據流處理節點和第二數據流處理節點；以及

所述將所述待處理數據流和所述壓力測試數據流從所述作為入口的數據流處理節點輸入至所述數據流系統，包括：

將所述待處理數據流從所述第一數據流處理節點輸入至所述數據流系統，并將所述壓力測試數據流從所述第二數據流處理節點輸入至所述數據流系統。

6.根據權利要求1所述的方法，其特征在于，所述基于所確定的延遲時間，確定壓力測試是否通過，包括：

響應于確定所述延遲時間小于預設延遲時間閾值，確定壓力測試通過；

響應于確定所述延遲時間不小于所述預設延遲時間閾值，確定壓力測試未通過。

7.一種用于數據流系統的壓力測試裝置，其特征在于，所述數據流系統包括用于對數據流進行處理的數據流處理節點集合，所述數據流從數據流處理節點集合中的、作為入口的數據流處理節點流入并在流經數據流處理節點集合中的至少一個數據流處理節點之后流出所述數據流系統，所述裝置包括：

解析單元，配置用于響應于接收到壓力測試指令，對待處理數據流進行解析，生成壓力測試數據流；

輸入單元，配置用于將所述待處理數據流和所述壓力測試數據流從所述作為入口的數據流處理節點輸入至所述數據流系統；

確定單元，配置用于周期性地確定所述數據流系統處理所輸入的數據流中的數據的延遲時間，并基于所確定的延遲時間，確定壓力測試是否通過。

8.根據權利要求7所述的裝置，其特征在于，所述解析單元包括：

提取模塊，配置用于響應于接收到壓力測試指令，提取與所述待處理數據流中的每一個待處理數據相匹配的屬性信息，其中，屬性信息包括日期、客戶端標識和用戶標識；

生成模塊，配置用于基于所提取的屬性信息，生成壓力測試數據流。