performance_test.py

import wzl.MQTT
import json
from datetime import datetime
import random
import time

MQTT_USER = "test"
MQTT_PASSWORD = "test"

MQTT_BROKER = "localhost"#"134.130.225.37"#
MQTT_PORT = 1883
MQTT_VHOST = "/"

client = wzl.MQTT.Client.MQTTPublisher(MQTT_USER)
client.connect(MQTT_BROKER, MQTT_PORT, MQTT_VHOST + ":"+  MQTT_USER, MQTT_PASSWORD)
test=0
i=0
while True:
    i+=1
    test += random.random()-0.5
    client.publish(
        topic="quatsch"+"/OBJ-Environment/OBJ-0/VAR-TEST",
            payload=json.dumps({
                "value": [float(test)],
                "timestamp": datetime.utcnow().isoformat()+"Z",
                "covariance": None,
                "nonce": {},
                "hash": None,
                "unit": "P1"
            }),
            qos=0,
            )
    print(i)
    time.sleep(1)