Snowpark Pythonのセッションの作成

アプリケーションでSnowparkを使用するには、セッションを作成する必要があります。コードの記述に便利なように、パッケージやオブジェクトの名前をインポートすることもできます。

このトピックの内容:

セッションの作成

ライブラリを使用する最初のステップは、Snowflakeデータベースとのセッションを確立することです。

Sessionクラスをインポートします。

>>> from snowflake.snowpark import Session
Copy

認証には、 Python用Snowflakeコネクタ がサポートするのと同じメカニズムを使用します。

Python用Snowflakeコネクタの connect 関数で使用するのと同じパラメーター(例: アカウント名、ユーザー名など)を使用して、Snowflakeデータベースとのセッションを確立します。詳細については、PythonコネクタAPIのドキュメントの 接続関数パラメーター をご参照ください。

これらのパラメーター(例: accountuserrolewarehousedatabaseschema など)の名前と値を含むディクショナリ(dict)を構築します。

セッションを作成するには、

  1. Snowflakeに接続するためのパラメーターの名前と値を含むPythonディクショナリ(dict)を作成します。

  2. このディクショナリを Session.builder.configs メソッドに渡して、これらの接続パラメーターを持つビルダーオブジェクトを返します。

  3. buildercreate メソッドを呼び出して、セッションを確立します。

次の例では、接続パラメーターを含む 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()  
Copy

account パラメーターには、使用する アカウント識別子 を使用します。アカウント識別子にはsnowflakecomputing.comサフィックスが含まれていないことに注意してください。

注釈

この例は、セッションを作成する1つの方法を示していますが、プロキシサーバーや OAuth を使用した、デフォルトの認証方式、シングルサインオン(SSO)、多要素認証(MFA)、キーペア認証など、他にもいくつかの接続方法があります。詳細については、 Pythonコネクタの使用 をご参照ください。

セッションを閉じる

クエリの実行にセッションを使用する必要がなくなり、現在実行中のクエリをキャンセルする場合は、Sessionオブジェクトのcloseメソッドを呼び出します。例:

>>> new_session.close()  
Copy