Я хочу реализовать использование chunksize в pd.read_sql_query (), но когда я реализую код, возникает неожиданная ошибка параметра.Не уверен, что я упускаю что-то очевидное.
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'