我想在pd.read\u sql\u query()中实现chunksize的使用,但是当我实现代码时,出现了一个意外的参数错误。不确定我是否遗漏了一些明显的东西
def readFromSQL(SQLSentence, chunksize = None):
try:
engine = sa.create_engine(engine_definition)
return_value = pd.read_sql_query(SQLSentence, engine,
chunksize = chunksize)
except sa.exc.DBAPIError:
sys.exit("Error (DBAPIError)")
return(return_value)
pdvs = readFromSQL("SELECT GOOGLE.* \
,creation_time \
FROM [dbo].[DM_SOURCE_GOOGLE_DETAILS] AS GOOGLE\
JOIN \
( \
SELECT place_id \
,max(datetime) AS datetime \
, min(datetime) AS creation_time \
FROM [dbo].[DM_SOURCE_GOOGLE_DETAILS] \
GROUP BY place_id \
)AS date_updated \
ON GOOGLE.datetime = date_updated.datetime \
AND GOOGLE.place_id = date_updated.place_id", chunksize = 5)
但是我得到了以下错误readFromSQL()得到了一个意外的关键字参数'chunksize'
目前没有回答
相关问题 更多 >
编程相关推荐