FreeOpcUa / python-opcua

            return results, cont

    def new_historized_event(self, source_id, etype, period):

        with self._lock:

            _c_new = self._conn.cursor()

            table = self._get_table_name(source_id)

            # FIXME need to call vars(etype) to get all attributes as strings so proper table columns can be created

            # FIXME should a table already exist, but a new etype is supplied, table needs to be ALTERED

            self._datachanges_period[source_id] = period

            self._event_attributes[source_id] = etype.__dict__.keys()  # get fields (find a better way?)

            # create a table for the event which will store attributes of the Event object

            # note: Value/VariantType TEXT is only for human reading, the actual data is stored in VariantBinary column

            try:

                _c_new.execute('CREATE TABLE "{tn}" (Id INTEGER PRIMARY KEY NOT NULL,'

                               ' Timestamp TIMESTAMP,'

                               ' Time BLOB,'

                               ' ReceiveTime BLOB,'

                               ' LocalTime BLOB,'

                               ' EventId BLOB,'

                               ' EventType BLOB,'

                               ' Severity BLOB,'

                               ' Message BLOB,'

                               ' SourceName BLOB,'

                               ' SourceNode BLOB,'

                               ' ServerHandle BLOB)'.format(tn=table))

            except sqlite3.Error as e:

                self.logger.info('Historizing SQL Table Creation Error for events from %s: %s', source_id, e)

            self._conn.commit()

    def save_event(self, event):

        with self._lock:

        self._conn = sqlite3.connect(self._db_file, detect_types=sqlite3.PARSE_DECLTYPES, check_same_thread=False)

    def new_historized_node(self, node_id, period, count=0):

        with self._lock:

            _c_new = self._conn.cursor()

            table = self._get_table_name(node_id)

            self._datachanges_period[node_id] = period, count

            # create a table for the node which will store attributes of the DataValue object

            # note: Value/VariantType TEXT is only for human reading, the actual data is stored in VariantBinary column

            try:

                _c_new.execute('CREATE TABLE "{tn}" (Id INTEGER PRIMARY KEY NOT NULL,'

                               ' ServerTimestamp TIMESTAMP,'

                               ' SourceTimestamp TIMESTAMP,'

                               ' StatusCode INTEGER,'

                               ' Value TEXT,'

                               ' VariantType TEXT,'

                               ' VariantBinary BLOB)'.format(tn=table))

            except sqlite3.Error as e:

                self.logger.info('Historizing SQL Table Creation Error for %s: %s', node_id, e)

            self._conn.commit()

    def save_node_value(self, node_id, datavalue):

        with self._lock: