Khi sử dụng sqlalchemy, bạn nên chuyển động cơ chứ không phải kết nối thô:
engine = create_engine("mysql+mysqldb://...")
df.to_sql('demand_forecast_t', engine, if_exists='replace', index=False)
Ghi vào MySQL mà không cần sqlalchemy (vì vậy với việc chỉ định flavor='mysql' ) không được dùng nữa.
Khi có vấn đề là bạn có khung quá lớn để viết cùng một lúc, bạn có thể sử dụng chunksize từ khóa (xem docstring
). Vd:
df.to_sql('demand_forecast_t', engine, if_exists='replace', chunksize=10000)
