sqlalchemyを使用するときは、生の接続ではなくエンジンを渡す必要があります:
engine = create_engine("mysql+mysqldb://...")
df.to_sql('demand_forecast_t', engine, if_exists='replace', index=False)
sqlalchemyを使用せずにMySQLに書き込む(つまり、flavor='mysql'
を指定して )は非推奨です。
フレームが大きすぎて一度に書き込めないことが問題である場合は、chunksize
を使用できます。 キーワード(docstring
を参照してください。 )。例:
df.to_sql('demand_forecast_t', engine, if_exists='replace', chunksize=10000)