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)
