Add background KISS connection, log frames to database #20
|
@ -31,6 +31,11 @@ db_fields = ("id",
|
|||
"object_name",
|
||||
"path",
|
||||
"phg",
|
||||
"phg_dir",
|
||||
"phg_gain",
|
||||
"phg_height",
|
||||
"phg_power",
|
||||
"phg_range",
|
||||
"posambiguity",
|
||||
"raw",
|
||||
"raw_timestamp",
|
||||
|
@ -95,15 +100,17 @@ def main():
|
|||
attrib_values = ", ".join("?" * len(a.keys()))
|
||||
#sql = f"INSERT INTO frames ({attrib_names}) VALUES ({attrib_values})"
|
||||
sql = "INSERT INTO frames ("+attrib_names+") VALUES ("+attrib_values+")"
|
||||
print(sql)
|
||||
# Insert data
|
||||
conn.execute(sql, list(a.values()))
|
||||
conn.commit()
|
||||
try:
|
||||
# Insert data
|
||||
conn.execute(sql, list(a.values()))
|
||||
conn.commit()
|
||||
|
||||
# TODO remove packets that are older ('created') than a limit set in config.ini
|
||||
# "5 minutes" also works
|
||||
conn.execute("DELETE FROM frames WHERE created < DATETIME('now', '"+config['Settings']['keep_time']+"')")
|
||||
conn.commit()
|
||||
# TODO remove packets that are older ('created') than a limit set in config.ini
|
||||
# "5 minutes" also works
|
||||
conn.execute("DELETE FROM frames WHERE created < DATETIME('now', '"+config['Settings']['keep_time']+"')")
|
||||
conn.commit()
|
||||
except:
|
||||
print("Error with SQLite!")
|
||||
|
||||
conn.close()
|
||||
|
||||
|
|
|
@ -21,7 +21,12 @@ CREATE TABLE frames (
|
|||
object_format TEXT,
|
||||
object_name TEXT,
|
||||
path TEXT,
|
||||
phg TEXT,
|
||||
phg REAL,
|
||||
phg_dir TEXT,
|
||||
phg_gain REAL,
|
||||
phg_height REAL,
|
||||
phg_power REAL,
|
||||
phg_range REAL,
|
||||
posambiguity INT,
|
||||
raw TEXT,
|
||||
raw_timestamp TEXT,
|
||||
|
|
Loading…
Reference in New Issue
Block a user