gps303/evstore.py

   1 from logging import getLogger
   2 from sqlite3 import connect
   3
   4 __all__ = ("initdb", "stow")
   5
   6 log = getLogger("gps303")
   7
   8 DB = None
   9
  10 SCHEMA = """create table if not exists events (
  11     timestamp real not null,
  12     imei text,
  13     clntaddr text not null,
  14     proto int not null,
  15     payload blob
  16 )"""
  17
  18
  19 def initdb(dbname):
  20     global DB
  21     DB = connect(dbname)
  22     DB.execute(SCHEMA)
  23
  24
  25 def stow(clntaddr, timestamp, imei, proto, payload):
  26     assert DB is not None
  27     parms = dict(
  28         zip(
  29             ("clntaddr", "timestamp", "imei", "proto", "payload"),
  30             (str(clntaddr), timestamp, imei, proto, payload),
  31         )
  32     )
  33     log.debug("inserting %s", parms)
  34     DB.execute(
  35         """insert or ignore into events
  36                 (timestamp, imei, clntaddr, proto, payload)
  37                 values (:timestamp, :imei, :clntaddr, :proto, :payload)""",
  38         parms,
  39     )
  40     DB.commit()