from sqlalchemy.engine import create_engine
import urllib.parse
connection_url = f"snowflake://{user}:@{account}/{database}/{schema}?warehouse={warehouse}&authenticator=oauth&token={urllib.parse.quote(access_token)}"
engine = create_engine(connection_url)
with engine.begin() as connection:
print(connection.execute('select count(*) from lineitem').fetchone())
2条答案
按热度按时间4uqofj5v1#
使用
snowflake.connector.connect
创建到数据库的PEP-249连接-请参阅文档。然后使用create_engine
(docs)的参数creator
-它接受返回PEP-249连接的可调用对象。如果使用它,则URL参数将被忽略。示例代码:
vybvopom2#
我得到了这个工作,但只是在连接URL中添加更多的参数:
如果您不想自己构造URL,可以使用
snowflake.sqlalchemy.URL
,如下所示: