def on_message(client, userdata, msg):
print(msg.topic+" "+str(msg.payload))
if msg.topic == id + '-response':
- print 'port is', str(msg.payload)
+ port = msg.payload
+ print 'port is', str(port)
+ print 'run ssh user@autossh.suanzi.ai -p ' + str(port) + ' to connect to ' + id + ' device'
client = mqtt.Client()
client.on_connect = on_connect
if __name__ == '__main__':
mac = hex(get_mac())
- id = os.getenv('USER') + '-' + '{:0>12}'.format(mac[2:13])
+ id = os.getenv('USER') + '-' + '{:0>12}'.format(mac[2:-1])
print 'id is: ' , id
client = MyClient(id)
client.connect(MQTT_SERVER, MQTT_PORT, 60)