ungleich-public/lorawan
6
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Separate notify and insert

Browse source
This commit is contained in:
Nico Schottelius 2016-11-02 16:43:30 +01:00
parent 3e325a5c6a
commit 79061b6cf8
1 changed files with 13 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
receiver/ttn-receiver.py
View file

@ -42,13 +42,23 @@ def insert_json(provider, data, payload='', deveui=''):
cursor.execute("insert into packets values (DEFAULT, DEFAULT, %s, %s, %s, %s)", (provider, data, payload, deveui))
cursor.connection.commit()
notify="{}/{}".format(deveui, payload)
cursor.execute("select pg_notify ('lora', %s)", (notify))
cursor.connection.commit()
conn.close()
except Exception as e:
print("DB Insert failed: %s" % e)
notify(payload, deveui)
def notify(payload='', deveui=''):
try:
conn = psycopg2.connect("dbname=lorawan")
cursor = conn.cursor()
notify="{}:{}".format(deveui, payload)
cursor.execute("select pg_notify ('lora', %s)", (notify))
cursor.connection.commit()
except Exception as e:
print("DB Notify failed: %s" % e)
if __name__ == '__main__':
mqttc= mqtt.Client()
mqttc.on_connect=on_connect