Class SmartNodeUser

tests/load/locustfile.py:71–145

模拟普通用户提交传输请求。 等待时间 0.1-1.0 秒，模拟真实用户操作间隔。

# ---------------------------------------------------------------------------

class SmartNodeUser(HttpUser):
    """模拟普通用户提交传输请求。

    等待时间 0.1-1.0 秒，模拟真实用户操作间隔。
    """

    wait_time = between(0.1, 1.0)

    @task(5)
    def submit_fixed_request(self):
        """高权重：提交固定类型（TASK_CMD/高优先级）的请求。"""
        payload = _fixed_payload()
        with self.client.post(
            "/api/request",
            json=payload,
            catch_response=True,
            name="/api/request[fixed]",
        ) as resp:
            if resp.status_code not in (200, 400, 429):
                resp.failure(f"Unexpected status: {resp.status_code}")
            else:
                resp.success()

    @task(3)
    def submit_random_request(self):
        """中权重：提交随机类型请求，覆盖多种数据类型。"""
        payload = _random_payload()
        with self.client.post(
            "/api/request",
            json=payload,
            catch_response=True,
            name="/api/request[random]",
        ) as resp:
            if resp.status_code not in (200, 400, 429):
                resp.failure(f"Unexpected status: {resp.status_code}")
            else:
                resp.success()

    @task(1)
    def submit_low_priority_request(self):
        """低权重：提交低优先级请求，压力测试下预期会被拒绝。"""
        payload = _fixed_payload(data_type="DATA_SLICE", priority=1)
        with self.client.post(
            "/api/request",
            json=payload,
            catch_response=True,
            name="/api/request[low_priority]",
        ) as resp:
            if resp.status_code not in (200, 400, 429):
                resp.failure(f"Unexpected status: {resp.status_code}")
            else:
                resp.success()

    @task(1)
    def check_health(self):
        """轮询健康检查接口，监控系统在高负载下的响应能力。"""
        with self.client.get("/api/health", catch_response=True) as resp:
            if resp.status_code != 200: