Při použití sqlalchemy byste měli předat engine a ne surové připojení:
engine = create_engine("mysql+mysqldb://...")
df.to_sql('demand_forecast_t', engine, if_exists='replace', index=False)
Zápis do MySQL bez sqlalchemy (takže se zadáním flavor='mysql' ) je zastaralá.
Pokud je problém v tom, že máte příliš velký rámec na zápis najednou, můžete použít chunksize klíčové slovo (viz řetězec dokumentů
). Např.:
df.to_sql('demand_forecast_t', engine, if_exists='replace', chunksize=10000)