mqtt_test.py

Go to the documentation of this file.

import paho.mqtt.client as mqtt
import math
import json
from time import sleep
 
# The callback for when the client receives a CONNACK response from the server.
def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
 
client = mqtt.Client()
client.on_connect = on_connect
 
client = mqtt.Client("PlotJuggler-test") #create new instance
 
client.connect("127.0.0.1", 1883, 60)
 
time = 0.0
 
while True:
    sleep(0.20)
    time += 0.20
    data = {
        "timestamp": time,
        "test_data": {
            "cos": math.cos(time),
            "sin": math.sin(time)
        }
    }
 
    ret = client.publish("plotjuggler/stuff", json.dumps(data), qos=0 )
    print( ret.is_published() )