【发布时间】:2021-04-08 03:22:17
【问题描述】:
我正在尝试使用以下代码将一个大型 csv 文件(500 万行)导入本地 MySQL 数据库:
代码:
import pandas as pd
from sqlalchemy import create_engine
engine = create_engine('mysql+mysqlconnector://[username]:[password]@[host]:[port]/[schema]', echo=False)
df = pd.read_csv('C:/Users/[user]/Documents/Sales_Records.csv')
df = df.head(27650)
df.to_sql(con= engine, name='data', if_exists='replace', chunksize = 50000)
如果我执行此代码,只要 df.head([row limit]) 小于 27650,它就可以工作。但是,只要我将此行限制增加一行,导入就会失败,现在数据是转移到 MySQL。有谁知道为什么会这样?
【问题讨论】: