Wanneer u sqlalchemy gebruikt, moet u de motor doorgeven en niet de onbewerkte verbinding:
engine = create_engine("mysql+mysqldb://...")
df.to_sql('demand_forecast_t', engine, if_exists='replace', index=False)
Schrijven naar MySQL zonder sqlalchemy (dus met het specificeren van flavor='mysql' ) is verouderd.
Als het probleem is dat je een te groot frame hebt om in één keer te schrijven, kun je de chunksize gebruiken trefwoord (zie de docstring
). Bijv.:
df.to_sql('demand_forecast_t', engine, if_exists='replace', chunksize=10000)