Почему параметр chunksize не работает в pandas.read_sql_query? - PullRequest
0 голосов
/ 01 июля 2019

Я хочу реализовать использование 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'

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...