Wenn Sie sqlalchemy verwenden, sollten Sie die Engine und nicht die Rohverbindung übergeben:
engine = create_engine("mysql+mysqldb://...")
df.to_sql('demand_forecast_t', engine, if_exists='replace', index=False)
Schreiben in MySQL ohne sqlalchemy (also mit Angabe von flavor='mysql' ) ist veraltet.
Wenn das Problem darin besteht, dass Sie einen zu großen Rahmen haben, um ihn auf einmal zu schreiben, können Sie die chunksize verwenden Schlüsselwort (siehe docstring
). ). Beispiel:
df.to_sql('demand_forecast_t', engine, if_exists='replace', chunksize=10000)
