SQLAlchemy engine.connect () завершается с ошибкой для Snowflake с использованием аутентификации пары ключей

Моя цель - написать to_sql() pandas в Snowflake, используя to_sql() . Я могу успешно запросить из Snowflake, используя read_sql() без проблем. Похоже, что to_sql () требует немного другой конфигурации, которую я не могу понять. Я пробовал два разных подхода, которые я изложил ниже.

Я догадываюсь, но могу ошибаться, что проблема заключается в аутентификации пары ключей. Когда я удаляю параметр закрытого ключа в обоих подходах, я получаю ошибку, что пароль отсутствует, а не особо непонятные ошибки, которые я получаю в противном случае. Возможно, отсутствие указанного пароля приводит к короткому замыканию попытки, и у меня действительно есть другая проблема.

С другой стороны, если есть лучший способ записать весь массив данных pandas в Snowflake, я с удовольствием предложу другие варианты.

Метод 1 из 3: Снежинка

edit: кажется, что sqllite - единственная поддерживаемая база данных, если соединение не является соединением SQLAlchemy .

Этот подход завершается с ошибкой DatabaseError: Execution failed on sql 'SELECT name FROM sqlite_master WHERE type='table' AND name=?;': not all arguments converted during string formatting

import snowflake

conn = snowflake.connector.connect(
    account=acct,
    warehouse=wh,
    database=db,
    schema=sc,
    user=usr,
    private_key=pkb,
)

df.to_sql('TABLENAME', con=conn, if_exists='replace', index=False)

Способ 2 - SQLAlchemy Engine

Я нашел документацию о том, как использовать закрытый ключ с SQLAlchemy. Однако происходит сбой с ValueError: Invalid IPv6 URL при вызове engine.connect() ...

from snowflake.sqlalchemy import URL
from sqlalchemy import create_engine

engine = create_engine(URL(
    account=acct,
    warehouse=wh,
    database=db,
    schema=sc,
    user=usr,
    connect_args={
        'private_key': pkb,
    }
))

with engine.connect() as conn:
    df.to_sql('TABLENAME', con=conn, if_exists='replace', index=False)

Отслеживание обеих этих ошибок очень длинное, но я рад опубликовать их, если это поможет устранить неполадки.

Всего 1 ответ


Я не знаю, что не так с № 2, но я обнаружил, что объединение № 1 и № 2 будет работать ...

import snowflake.connector
from sqlalchemy import create_engine

conn = snowflake.connector.connect(
    account=acct,
    warehouse=wh,
    database=db,
    schema=sc,
    user=usr,
    private_key=pkb,
)

engine = create_engine(f"snowflake://{acct}.snowflakecomputing.com", creator=lambda: conn)

try:
    with engine.connect() as c:
        # Note: the table name MUST be all lowercase for some reason, even though Snowflake uses all caps
        df.to_sql('TABLENAME'.lower(), con=c, if_exists='replace', index=False)
finally:
    engine.dispose()
    conn.close()

Есть идеи?

10000