je_load_density.wrapper.user_template.mqtt_user_template

Functions

set_wrapper_mqtt_user(user_detail_dict, **kwargs)

設定 MQTT User 的代理使用者 Configure MQTT User proxy

Classes

MqttUserWrapper(*args, **kwargs)

Locust MQTT User 包裝類別 Locust MQTT User wrapper class

class je_load_density.wrapper.user_template.mqtt_user_template.MqttUserWrapper(*args: Any, **kwargs: Any)

Bases: User

Locust MQTT User 包裝類別 Locust MQTT User wrapper class

Each task entry should look like:

{
    "method": "publish",        # publish | subscribe | connect | disconnect
    "broker": "127.0.0.1:1883",
    "topic": "telemetry/x",
    "payload": "...",
    "qos": 1,
    "retain": false,
    "username": "...",
    "password": "...",
    "client_id": "...",
    "name": "publish-telemetry"
}

host = '127.0.0.1:1883'

on_stop() → None

run_tasks() → None

wait_time = 0.1

je_load_density.wrapper.user_template.mqtt_user_template.set_wrapper_mqtt_user(user_detail_dict: Dict[str, Any], **kwargs) → type

設定 MQTT User 的代理使用者 Configure MQTT User proxy