devbox
寸_铁
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Locust初次体验【解决webUI没数据】_locust peekconsoleinput 存储空间不足

作者：寸_铁 | 2024-07-22 04:38:20

赞

踩

locust peekconsoleinput 存储空间不足

官方文档：What is Locust? — Locust 2.14.2 documentation

目录

Widows篇

Centos7 & Locust安装及踩坑

User、Httpuser、Fasthttpuser描述

Taskset、SequentialTaskSet描述

Widows篇

webUI模式跑起来没有数据。。。运行显示。？？？；

  1. E:\T_Work\other\WB_Locust\my_locustfiles>locust
  2. [2023-02-14 09:57:44,530] PC-20190108TSZQ/INFO/locust.main: Starting web interface at http://127.0.0.1:8089
  3. [2023-02-14 09:57:44,575] PC-20190108TSZQ/INFO/locust.main: Starting Locust 2.14.2
  4. [2023-02-14 09:57:44,708] PC-20190108TSZQ/WARNING/root: Exception in keyboard input poller: (8, 'PeekConsoleInput', '存储空间不足，无法处理
  5. 此命令。')
  6. [2023-02-14 10:00:13,088] PC-20190108TSZQ/INFO/locust.runners: Ramping to 5 users at a rate of 1.00 per second
  7. [2023-02-14 10:00:17,090] PC-20190108TSZQ/INFO/locust.runners: All users spawned: {"Boon_User": 1, "JUM_User": 1, "My_App": 1, "My_User": 1, "My_talent_rig": 0, "My_talent_swagger": 0, "Myc_User": 0, "VI_Us
  8. [2023-02-14 10:00:17,090] PC-20190108TSZQ/INFO/locust.runners: All users spawned: {"Boon_User": 1, "JUM_User": 1, "My_App": 1, "My_User": 1,
  9. er": 0, "ZJ_User": 1} (5 total users)
  10. End-My_App
  11. [2023-02-14 10:01:52,372] PC-20190108TSZQ/INFO/locust.runners: Ramping to 1 users at a rate of 1.00 per second
  12. [2023-02-14 10:01:52,373] PC-20190108TSZQ/INFO/locust.runners: All users spawned: {"Boon_User": 1, "JUM_User": 0, "My_App": 0, "My_User": 0,
  13. er": 0, "ZJ_User": 0} (1 total users)
  14. WARNING: gevent: Unhandled error with no watcher
  15. Traceback (most recent call last):
  16.   File "E:\Python\Lib\site-packages\gevent\libuv\loop.py", line 44, in python_queue_callback
  17.     def python_queue_callback(self, watcher_ptr, revents):
  18. KeyboardInterrupt
  19. Traceback (most recent call last):
  20.   File "E:\Python\Lib\site-packages\gevent\_ffi\loop.py", line 270, in python_check_callback
  21.     def python_check_callback(self, watcher_ptr): # pylint:disable=unused-argument
  22. KeyboardInterrupt

解决文案一：原因是gevent（协程，locust 压测要用到的）这个库版本不一致导致的，更新一下：

python.exe -m pip install --upgrade gevent==21.12.0 -i https://mirrors.aliyun.com/pypi/simple/

解决文案二：把‘locust’，'gevent', 'geventhttpclient', 'greenlet'，全部删掉，重新安装即可

重新安装出现警告

原因分析：安装package时中途中断

需要在目录【...\Python\Lib\site-packages】删除~ip文件夹后，再次重新安装，就正常运行有数据返回；

再次运行就可以打开Web-ui界面了

  

 

安装Locust

命行模式：python.exe -m pip install locust

代码段主要作用为创建用户或用户组角色【按wait_time、weight自定义选择执行】

User :表示要生成进行负载测试的系统的 HTTP“用户”

---HttpUser：比User类更常用，因为它添加了一个client属性，用来发送HTTP请求

task :表示用户要进行的操作【用户行为】

  • 方法前添加@task才会执行操作
  • 访问首页 → 登录 → 增、删改查 → homPage

tasks:指定为一个列表，那么每次执行任务时，它将从tasks属性中随机选择

tasks = {My_talent_rig: 1} 
--->每次执行
tasks = {My_talent_rig: 1,My_talent_swagger:5} 
--->My_talent_swagger执行次数是My_talent_rig的五倍

wait_time：时间间隔

  • 固定时间， 由constant(wait)函数提供

  • 区间随机时间: `between(min_wait, max_wait)函数

  • 自适应节奏时间: constant_pacing用于确保任务每 X 秒（最多）运行一次

  • 固定吞吐量，由constant_throughput函数提供

weight

        测试中，存在多个User Class，默认情况下locust将为每个User Class的实例的数量是相同的。通过设置weight属性，来控制locust为我们的User Class生成不同数量的实例。

命令行模式启动：locust --headless --users 5 --spawn-rate 1 --run-time 30m --csv=wb_example

框架是通过命令locust运行的，常用参数有：

  • -H：指定测试的主机地址（注：会覆盖Locust类指定的主机地址）
  • -f：指定测试脚本地址（注：脚本中必须包含一个Locust的衍生类）
  • --no-web：不启动web网页，而是直接开始运行测试，需提供属性-c和-r
  • -u or users：并发的用户数，与--no-web一起使用
  • -r or spawn-rate：每秒启动的用户数，与--no-web一起使用
  • -t or run-time：运行时间（单位：秒），与--no-web一起使用
  • csv : 保存CSV报告数据，默认保存文件【wb_example_exceptions.csv、wb_example_failures.csv、wb_example_stats.csv、wb_example_stats_history.csv】

  1. import os,sys
  2. pathS = os.getcwd()
  3. Project_Path = os.path.dirname(os.path.dirname(os.path.dirname(pathS)))
  4. root_Path = os.path.dirname(pathS)
  5. sys.path.append(Project_Path)
  6. sys.path.append(root_Path)
  7.  
  8. from locust import HttpUser, task , between , User,constant,constant_pacing, constant_throughput,events
  9. import os
  10. from other.WB_Locust.my_locustfiles.locustfile01 import B_Set_UP,M_Get
  11. from other.WB_Locust.my_locustfiles.locustfile_php import My_talent_swagger
  12. from other.WB_Locust.my_locustfiles.locustfile_php import My_talent_rig
  13. from other.WB_Locust.my_locustfiles.locustfile01 import My_App
  14.  
  15. class My_User(User): # 请求一个任务
  16.     host = "http://m-test.xxxxtest.cn"
  17.     wait_time = between(0.5, 5)
  18.     weight = 1
  19.     @task
  20.     def My_User(self):
  21.         pass
  22.  
  23. class VI_User(User): # 请求一个任务
  24.     host = "http://m-test.xxxxtest.cn"
  25.     wait_time = constant(3)
  26.     weight = 1
  27.     @task
  28.     def VI_User(self):
  29.         pass
  30.  
  31. class JUM_User(User): # 请求一个任务
  32.     host = "http://m-test.xxxxtest.cn"
  33.     wait_time = constant_pacing(3)
  34.     weight = 2
  35.     @task
  36.     def JUM_User(self):
  37.         pass
  38.  
  39. class Boon_User(User): # 请求一个任务
  40.     host = "http://m-test.xxxxtest.cn"
  41.     wait_time = constant_throughput(5)
  42.     weight = 2
  43.     @task
  44.     def Boon_User(self):
  45.         pass
  46.  
  47. class ZJ_User(HttpUser): # 请求一个任务组【TaskSet】
  48.     host = "http://m-test.xxxxtest.cn"
  49.     wait_time = between(2,3)
  50.     weight = 2
  51.     tasks = {B_Set_UP:1}
  52.     @task
  53.     def ZJ_User(self):
  54.         pass
  55.  
  56. class Myc_User(HttpUser): # 请求一个任务组【TaskSet】
  57.     host = "http://member-service.xxxxtest.cn"
  58.     tasks = {M_Get:2}
  59.     @task
  60.     def Myc_User(self):
  61.         pass
  62. class My_App(HttpUser): # 请求一个任务组【TaskSet】
  63.     host = "http://api-service.xxxxtest.cn"
  64.     tasks = {My_App:1}
  65.     @task
  66.     def My_App(self):
  67.         pass
  68.  
  69. class My_talent_swagger(HttpUser): 
  70.     wait_time = between(10,20)
  71.     host = "http://member-service.xxxxtest.cn"
  72.     tasks = {My_talent_swagger: 1}
  73.     @task
  74.     def My_talent_swagger(self):
  75.         pass
  76. class My_talent_rig(HttpUser):
  77.     wait_time = between(5,6)
  78.     host = "http://rig-portal.xxxxtest.cn"
  79.     tasks = {My_talent_rig: 1}
  80.     @task
  81.     def My_talent_rig(self):
  82.         pass
  83.  
  84. if __name__ == '__main__':
  85.     os.system("locust --headless --users 5 --spawn-rate 1 --run-time 30m --csv=wb_example")
  86.  
  87. # 命令行执行locust
  88. # locust --headless --users 10 --spawn-rate 1 --tun-time 1m -l -H https://m-test.xxxxtest.cn
  89. # --tags WB 只执行标记为WB的任务[debug调试]
  90. # locust --headless --users 10 --spawn-rate 1 --tun-time 1m -l -H https://m-test.xxxxtest.cn --tags WB
  91. # exclude-tags WB 执行标识不为WB的任务
前端--逻辑代码文件

请求值参：catch_response = True 为检查点，结合with使用

  1. @ 多重嵌套任务
  2. class xxx(TaskSet):
  3.         class AAA(TaskSet):
  4.                 @task
  5.                 def BBB(self):
  6.                     print('000')
  7.         class CCC(TaskSet):
  8.                 @task
  9.                 def EEE(self):
  10.                     print('123')
  11.                     with self.client.get("/shop/introduce/59/",catch_response=True) as Res:
  12.                         if "万表网" in Res.text:
  13.                             Res.success()
  14.                         else:
  15.                             Res.failure("No member message!")
  16.  
  1. # locustfile01.py 
  2.  
  3.  
  4.  
  5. import os,sys
  6. pathS = os.getcwd()
  7. Project_Path = os.path.dirname(os.path.dirname(os.path.dirname(pathS)))
  8. root_Path = os.path.dirname(pathS)
  9. sys.path.append(Project_Path)
  10. sys.path.append(root_Path)
  11.  
  12. from locust import HttpUser, task , between , tag,User,constant,constant_pacing,TaskSet,constant_throughput,events
  13. from other.WB_Locust.common.api_token import *
  14. from other.WB_Locust.Config import Config
  15. import json,time,random,requests
  16.  
  17. class SSet_UP():
  18.     def START_009(self):
  19.         K_token = WB_ApiMD.MD5_token(self,1,1)
  20.         Api_HeaderToKen = HeaderToken.Header_token(self,3, K_token)
  21.         Member_HeaderToKen = HeaderToken.Header_token(self, 5, K_token)
  22.         # PHP专用
  23.         # PHP_mParams = Config.php_mParams
  24.         # P_token = WB_ApiMD.MD5_token(self, 7, 5)
  25.         # Php_HeaderToKen = HeaderToken.Header_token(self, 2, P_token)
  26.         PHP_mParams = ""
  27.         P_token = ""
  28.         Php_HeaderToKen = ""
  29.         return K_token,Api_HeaderToKen,Member_HeaderToKen,Php_HeaderToKen,P_token,PHP_mParams
  30.  
  31. class B_Set_UP(TaskSet):
  32.     @task
  33.     class Test_HttpUser(TaskSet):
  34.         @tag('42470')
  35.         @task(3)
  36.         def view_goods(self):
  37.             self.client.get("/goods/42470")
  38.  
  39.         @tag('shoubiao')
  40.         @task(2)
  41.         def view_shoubiao(self):
  42.             self.client.get("/shoubiao.html")
  43.  
  44.         @tag('fenlei')
  45.         @task(1)
  46.         def view_fenlei(self):
  47.             self.client.get("/fenlei.html")
  48.             self.interrupt()
  49.  
  50.     @task
  51.     class Woman_UserA(TaskSet):
  52.         @task
  53.         def Woman_UserA(self):
  54.             self.client.get("/shop/59/")
  55.             self.interrupt()
  56.  
  57.     @task
  58.     class Woman_UserB(TaskSet):
  59.         @task
  60.         def Woman_UserB(self):
  61.             self.client.get("/goods/42471")
  62.  
  63.         @task
  64.         def Woman_UserC(self):
  65.             self.client.get("/goods/67")
  66.             self.interrupt()
  67.  
  68.     @task
  69.     class Woman_UserS(TaskSet):
  70.         @task
  71.         def Woman_UserB1(self):
  72.             self.client.get("/goods/16641")
  73.  
  74.         @task
  75.         def Woman_UserC2(self):
  76.             self.client.get("/goods/42823")
  77.             self.interrupt()
  78.  
  79.     @task
  80.     class SWoman_UserS(TaskSet):
  81.         '商城静态页面接口请求'
  82.         @tag('WB')
  83.         @task(2)
  84.         def SWoman_UserB1(self):
  85.             with self.client.get("/shop/introduce/59/",catch_response=True) as Res:
  86.                 if "万表网" in Res.text:
  87.                     Res.success()
  88.                 else:
  89.                     Res.failure("No member message!")
  90.         @tag('WB')
  91.         @task(2)
  92.         def SWoman_UserC2(self):
  93.             with self.client.get("/shop/dynamic/59/",catch_response=True) as Res:
  94.                 if "万表网" in Res.text:
  95.                     Res.success()
  96.                 else:
  97.                     Res.failure("No member message!")
  98.             self.interrupt()
  99.  
  100. class M_Get(TaskSet):
  101.     '会员资料接口请求'
  102.     def on_start(self):
  103.         Data_key = SSet_UP().START_009()
  104.         self.My_y = Data_key[2]
  105.  
  106.     def on_stop(self):
  107.         self.client.get('/member/loginOut',headers=self.My_y)
  108.  
  109.     @tag('WB')
  110.     @task(5)
  111.     def login(self):  # 会员登录接口请求
  112.         Url_headers = {'Content-Type': 'application/json', 'Connection': 'keep-alive',
  113.                     'User-Agent': 'Dalvik/2.1.0 (Linux; U; Android 8.1.0; Redmi Note 5 MIUI/V9.6.4.0.OEICNFD) WBIAO_MARKET_20190471_8.1.0 com.wbiao.wbapp 3.4.9#huawei# runningIn_1'}
  114.         Pcontent = {"identity": '188000000' + str(random.randint(00,99)), "identityType": "1", "password": 111111, "platformSource": "Mall",
  115.                     "remember": "true", "terminalType": "PC"}
  116.         Url_loring = 'http://member-service.xxxxtest.cn/member/login'
  117.         with self.client.post(url=Url_loring,data=json.dumps(Pcontent),catch_response=True,headers=Url_headers) as Res:
  118.             if "memberCode" in Res.text:
  119.                 Res.success()
  120.             else:
  121.                 Res.failure("Wrong")
  122.  
  123.     @tag('SH')
  124.     @task
  125.     def member_get(self):  # 获取个人资料
  126.         with self.client.get('/member/center/get',catch_response=True, headers=self.My_y) as Res:
  127.             if "5102252" in Res.text:
  128.                 Res.success()
  129.             else:
  130.                 Res.failure("No member message!")
  131.  
  132.     @tag('SH')
  133.     @task
  134.     def member_message(self):  # 获取会员基本信息
  135.         with self.client.get('/member/center/getMember',
  136.                              catch_response=True,
  137.                              headers=self.My_y) as Res:
  138.             if "5102252" in Res.text:
  139.                 Res.success()
  140.             else:
  141.                 Res.failure("No member message!")
  142.  
  143. class My_App(TaskSet): #api-APP请求
  144.     def on_start(self):
  145.         Data_key = SSet_UP().START_009()
  146.         self.K_token = Data_key[0]
  147.         self.HeaderToKen = Data_key[1]
  148.     def on_stop(self):
  149.         print("End-My_App")
  150.  
  151.     @tag('debug')
  152.     @task
  153.     def My_Cart(self):
  154.         app_mParams = ""
  155.         api_key = WB_ApiMD.api_get(app_mParams,'1','1')
  156.         K_word = api_key + '&wb-token=' + self.K_token + Config.T_keyword
  157.         with self.client.get('/api/cart/getList?' + api_key + WB_ApiMD.sign_R(K_word),
  158.                              headers=self.HeaderToKen,
  159.                              catch_response=True) as Res:
  160.             if "cartGoodsList" in Res.text:
  161.                 Res.success()
  162.             else:
  163.                 Res.failure("Faile")
  164. '''
  165. class My_talent_swagger(TaskSet): # Member swagger
  166.     def on_start(self):
  167.         Data_key = SSet_UP().START_009()
  168.         self.K_token = Data_key[0]
  169.         self.HeaderToKen = Data_key[3]
  170.     def on_stop(self):
  171.         self.interrupt()
  172.     @task
  173.     def talent_get(self): # 达人-获取图文信息
  174.         with self.client.get('/member/talentImageText/get?talentImageTextId=122',
  175.                              headers=self.HeaderToKen,
  176.                              catch_response=True) as Res:
  177.             if "talentImageTextId" in Res.text:
  178.                 Res.success()
  179.             else:
  180.                 Res.failure("Wrong")
  181.     @task
  182.     def talent_list(self): # 达人-查询列表
  183.         list_data = {
  184.           "pager": {
  185.             "now": 0,
  186.             "size": 5,
  187.             "total": 5
  188.           },
  189.           "search": [
  190.             {
  191.               "name": "string",
  192.               "value": "string"
  193.             }
  194.           ],
  195.           "sort": [
  196.             {
  197.               "asc": 'true',
  198.               "name": "string"
  199.             }
  200.           ]
  201.         }
  202.         with self.client.post('/member/talentImageText/getList',
  203.                               data=json.dumps(list_data),
  204.                               headers=self.HeaderToKen,
  205.                               catch_response=True) as Res:
  206.             if "talentImageTextId" in Res.text:
  207.                 Res.success()
  208.             else:
  209.                 Res.failure("Wrong")
  211. class My_talent_rig(TaskSet): # Rig Console
  212.     def on_start(self):
  213.         Data_key = SSet_UP().START_009()
  214.         self.K_token = Data_key[4]
  215.         self.HeaderToKen = Data_key[3]
  216.         self.php_mParams = Data_key[5]
  217.     def on_stop(self):
  218.         self.interrupt()
  219.     @task
  220.     def rig_t_get(self): # 达人类目详情
  221.         with self.client.get('/back/member/talent/class/get?id=1'+ self.php_mParams +'&sign='+self.K_token,
  222.                              headers=self.HeaderToKen,
  223.                              catch_response=True) as Res:
  224.             if 'name' in Res.text:
  225.                 Res.success()
  226.             else:
  227.                 Res.failure('Wrong')
  229.     @task
  230.     def rig_t_list(self): # 达人类目列表
  231.         with self.client.get('/back/member/talent/class/list?' + self.php_mParams + '&sign=' + self.K_token,
  232.                              headers=self.HeaderToKen,
  233.                              catch_response=True) as Res:
  234.             if 'name' in Res.text:
  235.                 Res.success()
  236.             else:
  237.                 Res.failure('Wrong')
  239.     @task
  240.     def rig_t_highCommissionGoods(self):  # 高佣金比例的商品列表
  241.         Pcontent = {"brandCodes":[70,176],"goodsCode":"","models":""}
  242.         with self.client.post('/back/member/talent/highCommissionGoods/list?' + self.php_mParams + '&sign=' + self.K_token,
  243.                               data= json.dumps(Pcontent),
  244.                               headers=self.HeaderToKen,
  245.                               catch_response=True) as Res:
  246.             if 'name' in Res.text:
  247.                 Res.success()
  248.             else:
  249.                 Res.failure('Wrong')
  250. '''
  251.  
  252. # class My_cart(HttpUser):
  253. #     host = "http://api-service.xxxxtest.cn"
  254. #     tasks = {My_cart:1}
  255. # if __name__ == '__main__':
  256. #     os.system("locust -f locustfile01.py --headless --users 1 --spawn-rate 1 --run-time 10")
后台-逻辑代码文件
  1. # locustfile_php.py
  2.  
  3.  
  4.  
  5. import os,sys
  6. pathS = os.getcwd()
  7. Project_Path = os.path.dirname(os.path.dirname(os.path.dirname(pathS)))
  8. root_Path = os.path.dirname(pathS)
  9. sys.path.append(Project_Path)
  10. sys.path.append(root_Path)
  11.  
  12. from locust import HttpUser, task , between , tag,User,constant,constant_pacing,TaskSet,constant_throughput,events
  13. from other.WB_Locust.common.api_token import *
  14. from other.WB_Locust.Config import Config
  15. import json,time,random,requests
  16.  
  17. class SSet_UP():
  18.     def START_009(self):
  19.         # K_token = WB_ApiMD.MD5_token(self,1,1)
  20.         # Api_HeaderToKen = HeaderToken.Header_token(self,3, K_token)
  21.         # Member_HeaderToKen = HeaderToken.Header_token(self, 5, K_token)
  22.         # PHP专用
  23.         PHP_mParams = Config.php_mParams
  24.         P_token = WB_ApiMD.MD5_token(self, 7, 5)
  25.         Php_HeaderToKen = HeaderToken.Header_token(self, 2, P_token)
  26.         # Rig_HeaderToKen = HeaderToken.Header_token(self, 2, K_token)
  27.         # app_mParams = ""
  28.         # api_key = WB_ApiMD.api_get(app_mParams, str(1), str(1))
  29.         # K_word = api_key + '&wb-token=' + K_token + Config.T_keyword
  30.         # Res = requests.get(url='http://api-service.xxxxtest.cn/api/cart/getList?' + api_key + WB_ApiMD.sign_R(K_word),
  31.         #                    headers=HeaderToKen)
  32.         # print(Res.text)
  33.         # print(Res.url)
  34.         # print(api_key)
  35.         # print(K_word)
  36.         # return K_token,Api_HeaderToKen,Member_HeaderToKen,Php_HeaderToKen,P_token,PHP_mParams
  37.         return Php_HeaderToKen, P_token, PHP_mParams
  38.  
  39. class My_talent_swagger(TaskSet): # Member swagger
  40.     def on_start(self):
  41.         print("My_talent_swagger")
  42.         Data_key = SSet_UP().START_009()
  43.         self.HeaderToKen = Data_key[0]
  44.     def on_stop(self):
  45.         self.interrupt()
  46.     @task
  47.     def talent_get(self): # 达人-获取图文信息
  48.         with self.client.get('/member/talentImageText/get?talentImageTextId=122',
  49.                              headers=self.HeaderToKen,
  50.                              catch_response=True) as Res:
  51.             if "talentImageTextId" in Res.text:
  52.                 Res.success()
  53.             else:
  54.                 Res.failure("Wrong")
  55.     @task
  56.     def talent_list(self): # 达人-查询列表
  57.         list_data = {
  58.           "pager": {
  59.             "now": 0,
  60.             "size": 5,
  61.             "total": 5
  62.           },
  63.           "search": [
  64.             {
  65.               "name": "string",
  66.               "value": "string"
  67.             }
  68.           ],
  69.           "sort": [
  70.             {
  71.               "asc": 'true',
  72.               "name": "string"
  73.             }
  74.           ]
  75.         }
  76.         with self.client.post('/member/talentImageText/getList',
  77.                               data=json.dumps(list_data),
  78.                               headers=self.HeaderToKen,
  79.                               catch_response=True) as Res:
  80.             if "talentImageTextId" in Res.text:
  81.                 Res.success()
  82.             else:
  83.                 Res.failure("Wrong")
  84.  
  85. class My_talent_rig(TaskSet): # Rig Console
  86.     def on_start(self):
  87.         print("My_talent_rig")
  88.         Data_key = SSet_UP().START_009()
  89.         self.K_token = Data_key[1]
  90.         self.HeaderToKen = Data_key[0]
  91.         self.php_mParams = Data_key[2]
  92.     def on_stop(self):
  93.         self.interrupt()
  94.     @task
  95.     def rig_t_get(self): # 达人类目详情
  96.         with self.client.get('/back/member/talent/class/get?id=1'+ self.php_mParams +'&sign='+self.K_token,
  97.                              headers=self.HeaderToKen,
  98.                              catch_response=True) as Res:
  99.             if 'name' in Res.text:
  100.                 Res.success()
  101.             else:
  102.                 Res.failure('Wrong')
  103.  
  104.     @task
  105.     def rig_t_list(self): # 达人类目列表
  106.         with self.client.get('/back/member/talent/class/list?' + self.php_mParams + '&sign=' + self.K_token,
  107.                              headers=self.HeaderToKen,
  108.                              catch_response=True) as Res:
  109.             if 'name' in Res.text:
  110.                 Res.success()
  111.             else:
  112.                 Res.failure('Wrong')
  113.  
  114.     @task
  115.     def rig_t_highCommissionGoods(self):  # 高佣金比例的商品列表
  116.         Pcontent = {"brandCodes":[70,176],"goodsCode":"","models":""}
  117.         with self.client.post('/back/member/talent/highCommissionGoods/list?' + self.php_mParams + '&sign=' + self.K_token,
  118.                               data= json.dumps(Pcontent),
  119.                               headers=self.HeaderToKen,
  120.                               catch_response=True) as Res:
  121.             if 'name' in Res.text:
  122.                 Res.success()
  123.             else:
  124.                 Res.failure('Wrong')
  125.  
  126.  
  127.  
  128. # class My_cart(HttpUser):
  129. #     host = "http://api-service.xxxxtest.cn"
  130. #     tasks = {My_cart:1}
  131. # if __name__ == '__main__':
  132. #     os.system("locust -f locustfile01.py --headless --users 1 --spawn-rate 1 --run-time 10")
执行
locust --headless --users 5 --spawn-rate 1 --run-time 30m --csv=wb_example

  • Type： 请求的类型，例如GET/POST。

  • Name：请求的路径。

  • reqs：当前请求的数量。

  • Fails：当前请求失败的数量。

  • Med：中间值，单位毫秒，一半的服务器响应时间低于该值，而另一半高于该值。

  • Avg：平均值，单位毫秒，所有请求的平均响应时间。

  • Min：请求的最小服务器响应时间，单位毫秒。

  • Max：请求的最大服务器响应时间，单位毫秒。

  • Average size：平均请求的大小，单位字节。

  • Req/s：是每秒钟请求的个数。

  • Failures/s：瞬时每秒失败数。

WebUI启动，均需要在命令行切换到执行文件的目录下，执行【locust】,对应打开链接即可 

Centos7 & Locust安装及踩坑

坑1：pip3 install locust ---> 99%无法安装，不是网络慢，就是各种依赖安装错误

解决：指定版本安装

pip3 install -i https://pypi.tuna.tsinghua.edu.cn/simple locustio==2.14.2

坑2：Locust安装成功后，提示如下

ModuleNotFoundError: No module named '_ctypes'

解决：重新安装依赖包【libffi-devel】，并重新编译，添加环境匹配

yum install libffi-devel
  1. 查看一下Centos下安装python3路径【/usr/local/python3】
  2. 查看一下安装python3源码包路径【/usr/local/python/Python-3.7.8rc1】
  3.  
  4. [root@localhost python]# cd Python-3.7.8rc1
  5. [root@localhost Python-3.7.8rc1]# ./configure --prefix=/usr/local/python3
  6. [root@localhost Python-3.7.8rc1]# make && make install
  7.  
  8. 重新编译后，添加环境匹配
  9. [root@localhost Python-3.7.8rc1]# vi /etc/profile
  10. export PATH=/usr/local/python3/bin:$PATH   ---->path添加一下python执行目录，并保存
  11.  
  12. [root@localhost Python-3.7.8rc1]# source /etc/profile
  13. [root@localhost Python-3.7.8rc1]# locust --version
  14. locust 2.14.2 from /usr/local/python3/lib/python3.7/site-packages/locust (python 3.7.8rc1)
  15.  
  16.  
  17.  
  18. 下面就是启动后应有的样子
  19. [root@localhost my_locustfiles]# locust
  20. [2023-03-01 16:27:57,070] localhost.localdomain/WARNING/locust.main: System open file limit '1024' is below minimum setting '10000'.
  21. It's not high enough for load testing, and the OS didn't allow locust to increase it by itself.
  22. See https://github.com/locustio/locust/wiki/Installation#increasing-maximum-number-of-open-files-limit for more info.
  23. [2023-03-01 16:27:57,071] localhost.localdomain/INFO/locust.main: Starting web interface at http://0.0.0.0:8089 (accepting connections from all network interfaces)
  24. [2023-03-01 16:27:57,080] localhost.localdomain/INFO/locust.main: Starting Locust 2.14.2
  25. [2023-03-01 16:30:04,736] localhost.localdomain/INFO/locust.runners: Ramping to 5 users at a rate of 1.00 per second
  26. [2023-03-01 16:30:08,739] localhost.localdomain/INFO/locust.runners: All users spawned: {"Boon_User": 1, "JUM_User": 1, "My_App": 1, "My_User": 1, "My_talent_rig": 0, "My_talent_swagger": 0, "Myc_User": 0, "VI_User": 0, "ZJ_User": 1} (5 total users)
  27. End-My_App
  28.  
  29.  
  30. 因为部署在Centos，外部访问还要对放开防火墙端口访问限制【8089】
  31. [root@localhost my_locustfiles]# firewall-cmd --zone=public --add-port=8087/tcp --permanent
  32. [root@localhost my_locustfiles]# systemctl reload firewalld

现在外部就可以访问了

User、Httpuser、Fasthttpuser描述

User:自定义请求方式，一个User代表一个线程

设定：电脑总共12个内核，可同时处理24个线程，设置12个节点，开始执行并发测试：

  • FastHttpUsers 单核每秒可以处理接近 5000 个请求，每秒可以处理接近 6万个请求，实际按5万算
  • HttpUser 单核每秒可以处理接近 850个请求（18款 MacBook Pro i7 上测试） 2.6GHz），12个内核，使用 httpuser 后，每秒可以处理接近9000 个请求

所以，电脑12个节点全开的情况下，
（1）12节点全开，电脑CPU不过载，9000并发以下的时候使用httpuser
（2）12节点全开，电脑CPU过载了，9000并发以上了，考虑使用FastHttpUsers
（3）12节点全开，电脑CPU过载了，并发超过6万了，拓展节点机器继续分布式压测，比如电脑的CPU总共12核，可以开启12个节点，最大化利用CPU资源，增加电脑发给服务器的每秒的请求数。

注意：很容易因为理解不深刻，导致电脑每秒发给服务的请求数不够，比如在自己电脑20万并发，实际每秒只发送了9000个请求，服务器每秒接收到的并不是20万并发的请求数，通过分布式执行来确保20万确实是并发上去了。
 

Taskset、SequentialTaskSet描述

  • TaskSet是指动作集合，就是将某个功能整合在一起，能够完成一系列动作;
  • 当执行到Class Test03的时候，会进入该类里面，执行里面的任务;
  • 当进入该类执行任务的时候，需要使用self.interrupt()来退出这个任务，否则任务将会一直在这类里面执行内部的任务，无法跳出执行其他任务;
  • SequentialTaskSet同样是指动作集合，比原TaskSet多了个功能，可以让任务，从上往下按顺序执行，同样的，也需要使用self.interrupt()来退出这个任务;
声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/寸_铁/article/detail/863552
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号