Update notify to listen to lora channel
This commit is contained in:
parent
79061b6cf8
commit
8d1808d6e0
1 changed files with 4 additions and 2 deletions
|
@ -2,13 +2,15 @@ import select
|
||||||
import psycopg2
|
import psycopg2
|
||||||
import psycopg2.extensions
|
import psycopg2.extensions
|
||||||
|
|
||||||
|
channel = "lora"
|
||||||
|
|
||||||
conn = psycopg2.connect("dbname=lorawan")
|
conn = psycopg2.connect("dbname=lorawan")
|
||||||
conn.set_isolation_level(psycopg2.extensions.ISOLATION_LEVEL_AUTOCOMMIT)
|
conn.set_isolation_level(psycopg2.extensions.ISOLATION_LEVEL_AUTOCOMMIT)
|
||||||
|
|
||||||
curs = conn.cursor()
|
curs = conn.cursor()
|
||||||
curs.execute("LISTEN test;")
|
curs.execute("LISTEN {};".format(channel))
|
||||||
|
|
||||||
print("Waiting for notifications on channel test")
|
print("Waiting for notifications on channel {}".format(channel))
|
||||||
while True:
|
while True:
|
||||||
if select.select([conn],[],[]) == ([],[],[]):
|
if select.select([conn],[],[]) == ([],[],[]):
|
||||||
print("Timeout")
|
print("Timeout")
|
||||||
|
|
Loading…
Reference in a new issue