FreeOpcUa / python-opcua

                    dv.SourceTimestamp = row[2]

                    dv.StatusCode = ua.StatusCode(row[3])

                    results.append(dv)

            except sqlite3.Error as e:

                self.logger.error('Historizing SQL Read Error for %s: %s', node_id, e)

            if nb_values:

                if len(results) > nb_values:

                    cont = results[nb_values].ServerTimestamp

                results = results[:nb_values]

            return results, cont

    def new_historized_event(self, source_id, ev_fields, period, count):

        with self._lock:

            _c_new = self._conn.cursor()

            self._datachanges_period[source_id] = period

            self._event_fields[source_id] = ev_fields

            table = self._get_table_name(source_id)

            columns = self._get_event_columns(ev_fields)

            # create a table for the event which will store fields generated by the source object's events

            # note that _Timestamp is for SQL query, _EventTypeName is for debugging, be careful not to create event

            # properties with these names

        self.logger = logging.getLogger(__name__)

        self._datachanges_period = {}

        self._db_file = path

        self._lock = Lock()

        self._event_fields = {}

        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)