Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import paho.mqtt.client as mqtt
- import paho.mqtt.publish as publish
- import datetime, random, time
- import ssl
- hostname = "54.200.7.109"
- port = 1883
- clientid = "AAA000"
- topic = "AAA111"
- def on_connect(client, userdata, flags, rc):
- print ("Connected with result code: %s" % rc)
- def on_disconnect(client, userdata, rc):
- print ("Disconnected with result code: %s" % rc)
- def on_message(client, userdata, msg):
- print(" - ".join((msg.topic, str(msg.payload))))
- def on_publish(client, userdata, mid):
- print ("Sent message")
- client = mqtt.Client(client_id=clientid)
- client.on_connect = on_connect
- client.on_disconnect = on_disconnect
- client.on_message = on_message
- client.on_publish = on_publish
- client.connect(hostname, port)
- client.subscribe(topic,0)
- #for x in range(10, 1000):
- # toSend = "1;2.1|4;"+str(random.uniform(-10,+10))+"&"+(datetime.datetime.now() + datetime.timedelta(days = -2000)).strftime('%Y-%m-%d %H:%M:%S')+";pass"
- #print(toSend)
- # client.publish(topic,payload = toSend,qos=0, retain=False)
- # time.sleep(5)
- client.loop_start()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement