Création d’une session pour Snowpark Python¶

Création d’une session¶

La première étape de l’utilisation de la bibliothèque consiste à établir une session avec la base de données Snowflake.

Importez la classe Session.

>>> from snowflake.snowpark import Session

Pour vous authentifier, vous utilisez les mêmes mécanismes que le connecteur Snowflake pour Python prend en charge.

Créez une session avec une base de données Snowflake avec les mêmes paramètres (par exemple, le nom du compte, le nom de l’utilisateur, etc.) que ceux que vous utilisez dans la fonction connect du connecteur Snowflake pour Python. Pour plus d’informations, consultez les paramètres de la fonction de connexion dans la documentation de l’API du connecteur Python.

Construisez un dictionnaire (dict) contenant les noms et les valeurs de ces paramètres (par exemple, account, user, role, warehouse, database, schema, etc.)

Pour créer la session :

1. Créez un dictionnaire Python (dict) contenant les noms et les valeurs des paramètres de connexion à Snowflake.

2. Transmettez ce dictionnaire à la méthode Session.builder.configs pour retourner un objet constructeur qui a ces paramètres de connexion.

3. Appelez la méthode create du builder pour établir la session.

L’exemple suivant utilise un dict contenant des paramètres de connexion pour créer une nouvelle session :

>>> 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()  

Pour le paramètre account, utilisez votre identificateur de compte. Notez que l’identificateur du compte ne comprend pas le suffixe snowflakecomputing.com.

Clôture d’une session¶

Si vous n’avez plus besoin d’utiliser une session pour exécuter des requêtes et que vous souhaitez annuler les requêtes en cours d’exécution, appelez la méthode de fermeture de l’objet Session. Par exemple :

>>> new_session.close()