bug fixes: sqlite writer with sqlalchemy

2024-02-02 19:18:23 -06:00 · 2024-02-02 19:18:23 -06:00 · c3fd371cb7
parent 0ac7e68bbd
commit c3fd371cb7
1 changed files with 1 additions and 1 deletions
--- 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()