c2/mqtt-py/mqtt-test.py

18 lines
505 B
Python

import paho.mqtt.client as mqtt
mqttc = mqtt.Client(client_id="", clean_session=True, userdata=None, transport="tcp")
mqttc.username_pw_set("thiessen", password="h82b7782")
mqttc.tls_set(ca_certs="/home/bryan/develop/mqttpy/certs/cert4.pem")
mqttc.connect("mqtt.tnet.space", port=8883)
mqttc.loop_start()
while True:
payload = input("Enter payload: ")
result = mqttc.publish("home/mqtt_test/in", payload)
result.wait_for_publish()
print(result.rc, result.mid, result.is_published())