mqtt-client.py

   1 #!/usr/bin/env python2
   2
   3 from subprocess import call, Popen, PIPE, STDOUT
   4 import paho.mqtt.client as mqtt
   5 import argparse
   6
   7 ID = 'rpdzkj'
   8 MQTT_SERVER = 'mqtt.suanzi.zi'
   9 MQTT_PORT = 1883
  10
  11 SSH_SERVER = 'autossh.suanzi.ai'
  12 PORT_RANGE = (20000, 30000)
  13 USER = 'autossh'
  14 PASSWORD = 'hard2guess'
  15 #
  16 #def run_ssh (port):
  17 #    pass
  18 #
  19 #
  20 #class MyClient(mqtt.Client):
  21 #    def __init__(self):
  22 #
  23 #
  24 #
  25 def on_connect(client, userdata, flags, rc):
  26     client.subscribe("rpdzkj-response")
  27     print("Connected with result code "+str(rc))
  28     client.publish('rpdzkj-request', 33)
  29
  30 def on_message(client, userdata, msg):
  31     print(msg.topic+" "+str(msg.payload))
  32     if msg.topic == 'rpdzkj-rsponse':
  33         print str(msg.payload)
  34
  35 if __name__ == '__main__':
  36 #    parser = argparse.ArgumentParser(description='Choose an avaiable port and run autossh.')
  37 #    parser.add_argument('-i', '--id', dest='id', help='board unique id, rpdzkj|firefly', required=True)
  38 #    args = parser.parse_args()
  39 #    id = args.id
  40 #
  41     client = mqtt.Client()
  42     client.on_connect = on_connect
  43     client.on_message = on_message
  44     client.connect(MQTT_SERVER, MQTT_PORT, 60)
  45     client.loop_forever()