Locust 在暂时收到错误 500 后停止

Question

当测试的 https 网站前的负载均衡器故障转移时，这会在几秒钟内产生一些 HTTPError 500，然后 Locust 挂起：

• 响应时间图停止（空图）
• 每秒的总请求数变成错误的绿色扁平线。 如果我只是停止并开始测试，locust 会重新启动正确监控响应时间。
• 我们可以在“失败”选项卡中看到一些 HTTPError 500

这是一个错误吗？ 如何确保 Locust 手动或超时杀死并重新启动用户？

我尝试定期“立即重新安排任务”没有帮助。

我的 locustfile.py：

#!/usr/bin/env python
import time
import random
from locust import HttpUser, task, between, TaskSet
from locust.exception import InterruptTaskSet, RescheduleTaskImmediately

URL_LIST = [
"/url1",
"/url2",
"/url3",
]

class QuickstartTask(HttpUser):
    wait_time = between(0.1, 0.5)
    connection_timeout = 15.0
    network_timeout = 20.0

    def on_start(self):
        # Required to use the http_proxy & https_proxy
        self.client.trust_env = True
        print("New user started")
        self.client.timeout = 5
        self.client.get("/")
        self.client.get("/favicon.ico")
        self.getcount = 0

    def on_stop(self):
        print("User stopped")

    @task
    def track_and_trace(self):
        url = URL_LIST[random.randrange(0,len(URL_LIST))]
        self.client.get(url, name=url[:50])
        self.getcount += 1
        if self.getcount > 50 and (random.randrange(0,1000) > 990 or self.getcount > 200):
            print(f'Reschedule after {self.getcount} requests.')
            self.client.cookies.clear()
            self.getcount = 0
            raise RescheduleTaskImmediately

Answer 1

每个蝗虫都在一个线程中运行。如果线程被阻塞，它不会采取进一步的行动。

self.client.get(url, name=url[:50], timeout=.1)

这样的东西可能是你需要的，当你得到一个 http 超时异常时，可能会使用 try/except 来做一些不同的事情。

Answer 2

根据我的经验，您使用 Locust 用户界面上的图表描述的问题与您的 Locust 用户遇到的错误无关。如果您有多个人试图同时访问 Locust UI，我已经看到了这种行为。 Locust 使用 Flask 来创建和提供 UI。 Flask 本身（Locust 使用它的方式）不能很好地处理多个连接。

如果人 A 开始使用 Locust UI 并开始测试，他们将看到统计数据和一切正常，直到人 B 加载 Locust UI。然后，B 人会看到一切正常，但 A 人会遇到您所描述的问题，测试似乎停滞不前，图表没有正确更新。在那种状态下，有时开始一个新的测试会暂时解决它，有时你需要刷新。无论哪种方式，A 和 B 都会为工作 UI 互相争斗。

在这种情况下，解决方案是使用诸如 Nginx 之类的东西将 Locust 置于反向代理之后。 Nginx 然后维护与 Locust 的单一连接，所有用户都通过 Nginx 连接。然后，Locust 的用户界面应继续为所有连接的用户工作，并正确更新统计数据和图表。