Har kommit en bit på väg men har problem med denna del, när en post läggs till av en annan process så kommer den inte upp här.
Tanken är att ha en process som skriver data till en tabell (fungerar) och ha fler oberoende processer (som denna) som läser ut senaste värdet när det har ändrat sig.
Denna läser bara ut senaste data en gång när den startar, försökte med cursor.execute("RESET QUERY CACHE") men det gjorde bara att try: satsen failade och jag hamnade i except:
Är detta rätt väg eller finns det en bättre väg att läsa ut bara nya poster?
Kod: Markera allt
try:
while True:
# read data from database
try:
cursor.execute("SELECT * FROM indicators ORDER BY ind_id DESC LIMIT 1")
row = cursor.fetchone()
if (row["ind_stored"] != old):
print "New data: ", row["ind_status"], row["ind_stored"], row["ind_id"]
old = row["ind_stored"]
#cursor.execute("RESET QUERY CACHE")
except:
print "Could not read data"
break
finally:
# disconnect from server
db.close()
