#!/usr/bin/env python
import mosquitto
import json
import os
URLFMT = "%s,%s"
def on_message(msg):
try:
data = json.loads(str(msg.payload))
except:
print "Can't decode payload"
try:
f = open('/var/www/location.current', 'w')
f.write(URLFMT % (data['lat'], data['lon']))
f.close()
except Exception, e:
print "Can't write file: %s" % str(e)
mqttc = mosquitto.Mosquitto("locator")
mqttc.on_message = on_message
mqttc.connect("127.0.0.1", 1883, 60)
mqttc.subscribe("mqttitude/#", 0)
while mqttc.loop() == 0:
pass