locust工具學習筆記（三）

阿新 • • 發佈：2021-01-23

locust工具學習筆記（三）

虛擬使用者數分配和權重的關係

1、一個場景檔案中如果定義多個使用者類，用來對不同使用者行為進行壓測時，可以用weight屬性來控制使用者行為執行權重

2、當用戶權重不足1人時，則會被忽略（如果權重為5:1時如果啟動3個使用者，則配比是2.5：0.5，不足一人時使用者行為2不會被執行）

from locust import User, task, constant

class UserBehavior1(User):
  wait_time = constant(1)
  weight = 2
  @task
  def task_1(self):
    print("使用者行為1")

class UserBehavior2(User):
  wait_time = constant(1)
  weight = 1
  @task
  def task_2(self):
    print("使用者行為2")

[2021-01-20 11:28:06,190] 910lanmingyong/INFO/locust.main: Starting web interface at http://0.0.0.0:8089 (accepting connections from all network interfaces)
[2021-01-20 11:28:06,197] 910lanmingyong/INFO/locust.main: Starting Locust 1.3.1
[2021-01-20 11:28:24,846] 910lanmingyong/DEBUG/locust.runners: Updating state to 'spawning', old state was 'ready'
[2021-01-20 11:28:24,846] 910lanmingyong/INFO/locust.runners: Spawning 10 users at the rate 1 users/s (0 users already running)...
使用者行為1
使用者行為1
使用者行為1
使用者行為1
使用者行為1
使用者行為2
使用者行為1
使用者行為2
使用者行為1
使用者行為2
使用者行為1
使用者行為2
使用者行為1
使用者行為2
使用者行為2
使用者行為1
使用者行為2
使用者行為1
使用者行為1
使用者行為2
使用者行為2
使用者行為1
使用者行為1
使用者行為2
使用者行為1
使用者行為1
使用者行為2
使用者行為2

Tasks屬性

一般情況下需要測試的使用者行為只需要在使用者類的使用者行為方法上新增@task修飾符即可，但是不在使用者類中編寫使用者行為程式碼，而是引用外部使用者行為方法時就可以死使用tasks屬性實現。

from locust import User, task, constant


def task_1(self):
  print("使用者行為1")

def task_2(self):
  print("使用者行為2")

class UserBehavior(User):
  wait_time = constant(1)
  tasks = [task_1,task_2]

  #如果需要設定權重則為
  # tasks = {task_1:1, task_2:2}

[2021-01-20 12:55:38,120] 910lanmingyong/INFO/locust.runners: All users spawned: UserBehavior: 4 (0 already running)
使用者行為2
使用者行為1
使用者行為1
使用者行為1
使用者行為1
使用者行為1
使用者行為2
使用者行為1
使用者行為2

from locust import User, task, constant


def task_1(self):
  print("使用者行為1")

def task_2(self):
  print("使用者行為2")

class UserBehavior(User):
  wait_time = constant(1)
  # tasks = [task_1,task_2]

  #如果需要設定權重則為
  tasks = {task_1:1, task_2:2}

[2021-01-20 12:57:43,757] 910lanmingyong/INFO/locust.runners: Spawning 3 users at the rate 1 users/s (0 users already running)...
使用者行為2
使用者行為2
使用者行為2
[2021-01-20 12:57:45,758] 910lanmingyong/INFO/locust.runners: All users spawned: UserBehavior: 3 (0 already running)
使用者行為2
使用者行為1
使用者行為1
使用者行為2
使用者行為2
使用者行為1

tag修飾符

@tag修飾符主要是用例管理測試方法的執行，在測試方法上加上一個或者多個@tag修飾符，就可以在執行測試時通過@tag修飾符執行指定測試集合，而且它不會影響全域性的任務收集。

在執行測試時，使用 -T 或者 -E 來挑選測試集合

-T 選中的集合

-E 排除選中的集合

例子如下：

from locust import task, constant, HttpUser, tag


class MyUser(HttpUser):
  wait_time = constant(1)
  @tag("smoke")
  @task(1)
  def task_1(self):
    print("my task1")

  @tag("test_env")
  @task(1)
  def task_2(self):
    print("my task2")

  @tag("pre_env")
  @task(1)
  def task_3(self):
    print("my task3")

  @tag("pre_env")
  @tag("test_env")
  @task(1)
  def task_4(self):
    print("my task4")


#locustfile_dome9.py  -T smoke  只執行tag=smoke標籤測試集
E:\PyProject\Learning>locust -f E:\PyProject\Learning\locusti\locustfile_dome9.py -T smoke
[2021-01-21 12:55:52,296] 910lanmingyong/INFO/locust.main: Starting web interface at http://0.0.0.0:8089 (accepting connections from all network interfaces)
[2021-01-21 12:55:52,302] 910lanmingyong/INFO/locust.main: Starting Locust 1.3.1
[2021-01-21 12:56:01,725] 910lanmingyong/INFO/locust.runners: Spawning 5 users at the rate 1 users/s (0 users already running)...
my task1
my task1
my task1
my task1
my task1
my task1
my task1
my task1
my task1
my task1

#locustfile_dome9.py  -E smoke 不執行tag=smoke測試集
E:\PyProject\Learning\locusti\locustfile_dome9.py -E smoke
[2021-01-21 12:59:29,493] 910lanmingyong/INFO/locust.main: Starting web interface at http://0.0.0.0:8089 (accepting connections from all network interfaces)
[2021-01-21 12:59:29,499] 910lanmingyong/INFO/locust.main: Starting Locust 1.3.1
[2021-01-21 12:59:37,535] 910lanmingyong/INFO/locust.runners: Spawning 5 users at the rate 2 users/s (0 users already running)...
my task2
my task2
my task2
my task3
my task2
my task3
my task4
my task4
[2021-01-21 12:59:39,557] 910lanmingyong/INFO/locust.runners: All users spawned: MyUser: 5 (0 already running)
my task3
my task4
my task4
my task2
my task4
my task2
my task2
my task2
my task2
my task4
my task4
my task4
my task3

TaskSet類

TaskSet類定義了每個使用者的任務集合。每一個Locust啟動的使用者都會從TaskSet中隨機挑選一個任務執行，如果配置權重則按權重配比挑選執行。

第一種使用方式：

使用tasks屬性將多個TaskSet子類巢狀在一起

from locust import task, constant, HttpUser, tag, TaskSet, User


class MyUser1(TaskSet):
  wait_time = constant(1)

  @task
  def task_1(self):
    print("my task1")

  @task
  def task_2(self):
    print("my task2")


class MyUser2(TaskSet):

  @task
  def task_3(self):
    print("my task3")

  @task
  def task_4(self):
    print("my task4")


class MyUserAll(User):
  wait_time = constant(1)
  tasks = {MyUser1:1,MyUser2:2}

  @task
  def task_5(self):
    print("my task5")

  @task
  def task_6(self):
    print("my task6")
    
#執行輸出
[2021-01-22 16:35:45,634] 910lanmingyong/INFO/locust.main: Starting web interface at http://0.0.0.0:8089 (accepting connections from all network interfaces)
[2021-01-22 16:35:45,641] 910lanmingyong/INFO/locust.main: Starting Locust 1.3.1
[2021-01-22 16:35:54,929] 910lanmingyong/INFO/locust.runners: Spawning 5 users at the rate 1 users/s (0 users already running)...
my task2
my task1
my task4
my task2
my task4
my task5
my task1
my task4
my task2
my task6
[2021-01-22 16:35:58,933] 910lanmingyong/INFO/locust.runners: All users spawned: MyUserAll: 5 (0 already running)
my task1
my task3
my task1
my task6
my task4
my task2
my task3
my task1
my task3
my task3
my task1
my task3

第二種使用方式：

TaskSet類的相互巢狀，可以實現實際測試中複雜的場景要求

from locust import task, constant, HttpUser, tag, TaskSet, User


class MyUser1(TaskSet):
  wait_time = constant(1)

  @task(1)
  def task_1(self):
    print("my task1")

  @task(1)
  def task_2(self):
    print("my task2")

  @task(3)
  class MyUser2(TaskSet):

    @task(2)
    def task_3(self):
      print("my task3")

    @task(1)
    def task_4(self):
      print("跳出MyUser2，否則這個使用者就會一直執行在MyUser2中執行task_3任務")
      self.interrupt()



class MyUserAll(User):
  wait_time = constant(1)
  tasks = [MyUser1]
#[2021-01-22 17:01:42,488] 910lanmingyong/INFO/locust.main: Starting web interface at http://0.0.0.0:8089 (accepting connections from all network interfaces)
[2021-01-22 17:01:42,494] 910lanmingyong/INFO/locust.main: Starting Locust 1.3.1
[2021-01-22 17:01:49,780] 910lanmingyong/INFO/locust.runners: Spawning 5 users at the rate 1 users/s (0 users already running)...
my task1
跳出MyUser2，否則這個使用者就會一直執行在MyUser2中執行task_3任務
my task1
my task2
跳出MyUser2，否則這個使用者就會一直執行在MyUser2中執行task_3任務
my task3
my task2
my task3
my task3
my task3
跳出MyUser2，否則這個使用者就會一直執行在MyUser2中執行task_3任務
my task3
my task3
[2021-01-22 17:01:53,783] 910lanmingyong/INFO/locust.runners: All users spawned: MyUserAll: 5 (0 already running)
my task3
my task3
my task3
my task3
跳出MyUser2，否則這個使用者就會一直執行在MyUser2中執行task_3任務
my task3
跳出MyUser2，否則這個使用者就會一直執行在MyUser2中執行task_3任務
my task3
my task3
my task3
my task3
my task3
my task3
my task3
跳出MyUser2，否則這個使用者就會一直執行在MyUser2中執行task_3任務
跳出MyUser2，否則這個使用者就會一直執行在MyUser2中執行task_3任務
跳出MyUser2，否則這個使用者就會一直執行在MyUser2中執行task_3任務
my task3
my task3
跳出MyUser2，否則這個使用者就會一直執行在MyUser2中執行task_3任務
my task2

第三種使用方式：

在User類中可以嵌入TaskSet類，作為User的子類

from locust import task, constant,TaskSet, User

class MyUserAll(User):
  wait_time = constant(1)

  @task
  def task_1(self):
    print("my task1")
  @task
  class MyUser2(TaskSet):

    @task(3)
    def task_3(self):
      print("my task2")

    @task(1)
    def task_4(self):
      print("my task3")


'''
說明：
1、場景執行時MyUser1和MyUser2執行的權重是相同的
2、MyUser2任務執行時75%會執行task_2，25%會執行task_3
3、因為MyUser2中沒有self.interrupt()方法所以最後所有的使用者都會在執行task_3，和task_4
'''

[2021-01-22 19:07:01,255] 910lanmingyong/INFO/locust.runners: 5 Users have been stopped
[2021-01-22 19:07:11,342] 910lanmingyong/INFO/locust.runners: Spawning 5 users at the rate 2 users/s (0 users already running)...
my task1
my task1
my task1
my task2
my task1
my task3
my task1
my task3
[2021-01-22 19:07:13,346] 910lanmingyong/INFO/locust.runners: All users spawned: MyUserAll: 5 (0 already running)
my task1
my task2
my task3
my task1
my task2
my task3
my task2
my task3
my task2
my task2
my task2
my task3
my task2
my task2
my task3
my task2
my task2
my task3
my task2
my task2
my task2
my task2
my task2
my task2
my task2
my task2
my task2
my task2
my task3
my task2
my task3
my task2
my task2
my task2
my task2
my task3
my task3
my task2
my task3
my task2
my task3
my task3
my task2
my task2
my task3
my task2

TaskSet類還有其他的有用方法：

on_start()函式 locust使用者進入TaskSet之後首先會執行on_start()。

on_start()函式

locust使用者退出TaskSet之後會執行on_stop()。

locust屬性指向每個TaskSet所屬的loucst使用者例項。
parent屬性指向TaskSet的父類TaskSet，在TaskSet有巢狀的情況下使用，如果呼叫parent的TaskSet是最頂層的，則返回它所屬的locust使用者例項。
client屬性指向TaskSet所屬的父HttpLocust類的client屬性，self.client與self.locust.client效果相同。如果TaskSet所屬的父類是個Locust類，則無client屬性。
interrupt(reschedule=True) 方法頂層的TaskSet，不能呼叫這個方法。如果reschedule置為True時，從被巢狀任務出來馬上選擇新任務執行，如果reschedule置為False，從被巢狀任務出來後，隨機等待min_wait和max_wait之間的一段時間，再選擇新任務執行。
schedule_task(task_callable, args=None, kwargs=None, first=False) 方法將一個可呼叫的物件task_callable新增進某個Locust物件的任務選擇佇列，其中args和kwargs是傳遞給可呼叫物件的引數，如果first置為True，則將其加到任務選擇隊首。

歡迎大家關注我的訂閱號，會定期分享一些關於測試相關的文章，有問題也歡迎一起討論學習！

locust工具學習筆記（三）

技術標籤：效能測試軟體測試locust負載測試介面壓測 locust工具學習筆記（三）

locust工具學習筆記（一）

技術標籤：效能測試軟體測試locust 編寫locustfile檔案一份locustfile中，宣告至少一個從該類繼承的使用者類

locust工具學習筆記（四）

技術標籤：效能測試Pythonlocustpythonlocust壓力測試 SequentialTaskSet 類在locust中使用者（執行緒）執行任務是隨機的，如果需要讓任務執行有一定順序則可以將taskset繼承SequentialTaskSet 類來實現。

locust工具學習筆記（二）

技術標籤：效能測試介面自動化軟體測試locustpython Events事件 locust包含了一個事件類，為不同的事件提供hook，事件處理函式註冊該hook，基於event觸發處理函式實現事件驅動。

MySQL高階學習筆記（三）：Mysql邏輯架構介紹、mysql儲存引擎詳解

Mysql邏輯架構介紹總體概覽和其它資料庫相比，MySQL有點與眾不同，它的架構可以在多種不同場景中應用併發揮良好作用。主要體現在儲存引擎的架構上，外掛式的儲存引擎架構將查詢處理和其它的系統任務以及資料的儲存提

Spark學習筆記（三）-Spark Streaming

Spark Streaming支援實時資料流的可擴充套件（scalable）、高吞吐（high-throughput）、容錯（fault-tolerant）的流處理（stream processing）。

Java 學習筆記（三）之 ThreadLocal、InheritableThreadLocal、TransmittableThreadLocal

一、初識服務程式是由程序構成，程序是由無數個執行緒構成，執行緒是一組程式碼片段組成。在Java的多執行緒程式設計中，為保證多個執行緒對共享變數的安全訪問，通常會使用synchronized來保證同一時刻只有一個執行緒

Python socket學習筆記（三）

之前都是客戶端對伺服器的單執行緒操作。接下來學習 SocketServer 多執行緒 SockServer

Consul 學習筆記（三）之高可靠性

一. 背景在生產環境中，後臺服務眾多，當選擇使用 consul 做服務治理的時候，所有服務註冊到consul 上，若consul 掛掉，會影響整個平臺的業務執行，為了保證業務的穩定性，需要consul 不宕機持續對外提供服務，因此

OpenWAF學習筆記（三）—— 呼叫API時403？

OpenWAF安裝及SQL注入防護測試成功之後，簡單瞭解API的用法，GitHub上說明在這 --> openwaf_api

kafka學習筆記（三）kafka的使用技巧

概述上一篇隨筆主要介紹了kafka的基本使用包括叢集引數，生產者基本使用，consumer基本使用，現在來介紹一下kafka的使用技巧。

Linux 核心學習筆記（三）——資料結構與中斷

目錄Kernel Data StructuresLinked listsQueuesMapsBinary treesAlgorithmic Complexitytime ComplexityInterrupts and Interrupt Handlers

微服務分散式電商專案學習筆記（三）---- docker介紹安裝以及使用docker安裝軟體（2020/7/1）

其實在介紹docker的使用和安裝之前應該還要介紹虛擬機器的安裝與配置，以及虛擬網路的配置，但是我使用的是vmware，而視訊課使用的是vagrant，這一塊我簡看的，因此沒有過多的介紹，至於vmware的安裝配置和虛擬網路

Spring 學習筆記（三）：Spring Bean

1 Bean配置 Spring可以看做是一個管理Bean的工廠，開發者需要將Bean配置在XML或者Properties配置檔案中。實際開發中常使用XML的格式，其中<bean>中的屬性或子元素如下：

HTML學習筆記（三）HTML基礎

認識HTML HTML（英文Hyper Text Markup Language的縮寫）中文譯為“超文字標籤語言”，是一種用於建立網頁的標記語言。

kafka學習筆記（三）----quick start

（一）啟動kafka環境　　kafka要求jdk1.8以上，並且啟動kafka之前需要啟動zookeeper，這裡直接使用kafka自帶的zookeeper，但是官方說不久後kafka將不再需要zookeeper。

Python語言程式設計學習筆記（三）

第十四章元組、集合和字典整章內容： [x] 建立元組。 [x] 使用元組作為固定列表來防止新增、刪除或替換元素。

鎖-學習筆記（三）

常見資源附加的鎖資料庫鎖資料庫鎖有共享、更新、排他3種模式。雖然這3種鎖會影響使用者對資料庫中表資料的操作，但這3種鎖的產生原因與表的邏輯資料操作都沒有關係，與事務也沒關係。

Java 學習筆記（三）呼叫 bat 或 shell 指令碼執行

一、背景在某些程式中需要 Java 程式碼直接呼叫 bat 指令碼或 sh 指令碼執行，但是除了命令不一樣以外，所有的邏輯是一樣的，為此以下給出通用程式碼。

AngularJS 學習筆記（三）基本概念和用法之路由、模組、依賴注入

>>> 1、AngualrJS的模組化實現 PS：小圖是全域性變數，大圖是模組化的變數。

locust工具學習筆記（三）

locust工具學習筆記（三）

虛擬使用者數分配和權重的關係

Tasks屬性

tag修飾符

TaskSet類

相關推薦