为 Snowpark Python 创建会话¶
要在应用程序中使用 Snowpark,您需要创建一个会话。为了方便编写代码,您还可以导入包和对象的名称。
本主题内容:
创建会话¶
使用该库的第一步是与 Snowflake 数据库建立会话。
导入会话类。
>>> from snowflake.snowpark import Session
要进行身份验证,请使用与 Snowflake Connector for Python 支持的机制相同的机制。
使用您在 Snowflake Connector for Python 中的 connect
函数中使用的相同参数(例如,账户名、用户名等),与 Snowflak 数据库建立会话。有关更多信息,请参阅 Python Connector API 文档中的“connect 函数的参数”。
构造一个字典 (dict
),其中包含这些参数(例如 account
、user
、role
、warehouse
、database
、schema
等)的名称和值。
要创建会话,请执行以下操作:
创建一个 Python 字典 (
dict
),其中包含用于连接到 Snowflake 的参数的名称和值。将此字典传递给
Session.builder.configs
方法,以返回具有这些连接参数的生成器对象。调用
builder
的create
方法来建立会话。
以下示例使用包含连接参数的 dict
来创建新会话:
>>> connection_parameters = {
... "account": "<your snowflake account>",
... "user": "<your snowflake user>",
... "password": "<your snowflake password>",
... "role": "<your snowflake role>", # optional
... "warehouse": "<your snowflake warehouse>", # optional
... "database": "<your snowflake database>", # optional
... "schema": "<your snowflake schema>", # optional
... }
>>> new_session = Session.builder.configs(connection_parameters).create()
对于 account
参数,请使用 账户标识符。请注意,账户标识符不包含 snowflakecomputing.cn 后缀。
备注
此示例向您展示了创建会话的一种方式,但还有几种其他连接方式,包括:默认身份验证器、单点登录 (SSO)、多重身份验证 (MFA)、密钥对身份验证、使用代理服务器以及 OAuth。有关更多信息,请参阅 使用 Python Connector。
结束会话¶
如果您不再需要使用会话执行查询并且想要取消当前正在运行的任何查询,请调用该会话对象的 close 方法。例如:
>>> new_session.close()