hiplab/data-transport
hiplab
/
data-transport
mirror of https://github.com/lnyemba/data-transport
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

bug fixes: sqlite writer with sqlalchemy

This commit is contained in:
Steve Nyemba 2024-02-02 19:19:23 -06:00
parent c3fd371cb7
commit c3ebd32a40
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
transport/disk.py
View File

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