code: def _create_db(self):
          
          log.debug("Creating sqlite database")
          self._conn = sqlite3.connect(self._db_filename)
  
          # create table structure
          self._conn.cursor().execute("""
          CREATE TABLE IF NOT EXISTS {}
          (
            ts REAL,
            arbitration_id INTEGER,
            extended INTEGER,
            remote INTEGER,
            error INTEGER,
            dlc INTEGER,
            data BLOB
          )
          """.format(self.table_name))
          self._conn.commit()
  
          self._insert_template = "INSERT INTO {} VALUES (?, ?, ?, ?, ?, ?, ?)".format(self.table_name)
docs: Creates a new databae or opens a connection to an existing one.
  
          .. note::
              You can't share sqlite3 connections between threads (by default)
              hence we setup the db here. It has the upside of running async.