diff --git a/transport/disk.py b/transport/disk.py index f5f8a97..fab5eb1 100644 --- a/transport/disk.py +++ b/transport/disk.py @@ -218,7 +218,7 @@ class SQLiteWriter(SQLite,DiskWriter) : _data = [_data] _table = self.table if 'table' not in _args else _args['table'] _df = pd.DataFrame(_data) - _df.to_sql(_table,self._engine.connect()) + _df.to_sql(_table,self._engine.connect()if_exists='append',index=False) except Exception as e: print (e) SQLiteWriter.LOCK.release()