rgutierrez/resq
1
0
Fork 0
Code Issues 126 Pull requests 49 Projects Releases 4 Packages Wiki Activity Actions

Fix mqtt_sender script

Browse source
This commit is contained in:
root 2018-08-14 06:42:12 +08:00
parent 0bc1100240
commit 1584673e26
1 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
utils/mqtt_sender/mqtt_sender.py
View file

@ -27,7 +27,7 @@ def on_publish(client, userdata, mid):
def getRedis(i): def getRedis(i, client):
r = redis.StrictRedis(host='localhost', port=6379, db=0) r = redis.StrictRedis(host='localhost', port=6379, db=0)
while 1: while 1:
time.sleep(0) time.sleep(0)
@ -56,7 +56,7 @@ def main():
tls_version=ssl.PROTOCOL_TLSv1) tls_version=ssl.PROTOCOL_TLSv1)
client.connect("resqaws.jankstudio.com", 8883, 60) client.connect("resqaws.jankstudio.com", 8883, 60)
t = Thread(target=getRedis, args=(1,)) t = Thread(target=getRedis, args=(1, client))
t.start() t.start()
@ -65,6 +65,7 @@ def main():
pid = "/tmp/mqtt_sender.pid" #pid = "/tmp/mqtt_sender.pid"
daemon = Daemonize(app="mqtt_sender", pid=pid, action=main) #daemon = Daemonize(app="mqtt_sender", pid=pid, action=main)
daemon.start() #daemon.start()
main()