Saat menggunakan sqlalchemy, Anda harus melewati mesin dan bukan koneksi mentah:
engine = create_engine("mysql+mysqldb://...")
df.to_sql('demand_forecast_t', engine, if_exists='replace', index=False)
Menulis ke MySQL tanpa sqlalchemy (jadi dengan menentukan flavor='mysql'
) tidak digunakan lagi.
Jika masalahnya adalah Anda memiliki bingkai yang terlalu besar untuk ditulis sekaligus, Anda dapat menggunakan chunksize
kata kunci (lihat docstring
). Misal:
df.to_sql('demand_forecast_t', engine, if_exists='replace', chunksize=10000)