-
Notifications
You must be signed in to change notification settings - Fork 0
/
mqtt_client.py
36 lines (27 loc) · 909 Bytes
/
mqtt_client.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
import paho.mqtt.client as paho
import time
mqttc = paho.Client()
# Settings for connection
#host = "192.168.43.84" #phone
host = "192.168.137.1" #pc
topic = "Car"
# Callbacks
def on_connect(self, mosq, obj, rc):
print("Connected rc: " + str(rc))
def on_message(mosq, obj, msg):
print("[Received] Topic: " + msg.topic + ", Message: " + str(msg.payload) + "\n");
def on_subscribe(mosq, obj, mid, granted_qos):
print("Subscribed OK")
def on_unsubscribe(mosq, obj, mid, granted_qos):
print("Unsubscribed OK")
# Set callbacks
mqttc.on_message = on_message
mqttc.on_connect = on_connect
mqttc.on_subscribe = on_subscribe
mqttc.on_unsubscribe = on_unsubscribe
# Connect and subscribe
print("Connecting to " + host + "/" + topic)
mqttc.connect(host, port=1883, keepalive=60)
mqttc.subscribe(topic, 0)
# Loop forever, receiving messages
mqttc.loop_forever()