получение TypeError при использовании метода write_pandas

Использование решений из этого вопроса: как прочитать список файлов паркета из S3 в качестве фрейма данных pandas с помощью pyarrow?, Я импортирую следующее, чтобы скопировать данные из ведра s3 в таблицу снежинок:

          from snowflake.connector.pandas_tools import write_pandas

Когда я пытаюсь использовать метод "write_pandas", я получаю сообщение об ошибке:

          TypeError: __init__() missing 1 required positional argument: 'backend'

Вот мой код:

          conn = snow.connect(
        user="ll", 
        password="zzz",
        account="account",
        role="role",
        warehouse="WAREHOUSE",
        database="db",
        schema="C")

    s3 = s3fs.S3FileSystem(anon=False, key = 'AKI', secret = 'zzz')  
    pandas_dataframe = pq.ParquetDataset('s3://bucket/folder2/File.snappy.parquet', 
    filesystem=s3).read_pandas().to_pandas()


    write_pandas(conn, pandas_dataframe, "DATATABLE")

Что мне нужно сделать, чтобы добавить этот обязательный аргумент? Или есть другое решение?

0 ответов

Другие вопросы по тегам