snowflake.snowpark.Session¶

class snowflake.snowpark.Session(conn: ServerConnection, options: Optional[Dict[str, Any]] = None)[source]¶

Bases: object

Establishes a connection with a Snowflake database and provides methods for creating DataFrames and accessing objects for working with files in stages.

When you create a Session object, you provide connection parameters to establish a connection with a Snowflake database (e.g. an account, a user name, etc.). You can specify these settings in a dict that associates connection parameters names with values. The Snowpark library uses the Snowflake Connector for Python to connect to Snowflake. Refer to Connecting to Snowflake using the Python Connector for the details of Connection Parameters.

To create a Session object from a dict of connection parameters:

>>> connection_parameters = {
...     "user": "<user_name>",
...     "password": "<password>",
...     "account": "<account_name>",
...     "role": "<role_name>",
...     "warehouse": "<warehouse_name>",
...     "database": "<database_name>",
...     "schema": "<schema_name>",
... }
>>> session = Session.builder.configs(connection_parameters).create() 

Copy

To create a Session object from an existing Python Connector connection:

>>> session = Session.builder.configs({"connection": <your python connector connection>}).create() 

Copy

Session contains functions to construct a DataFrame like table(), sql() and read, etc.

A Session object is not thread-safe.

Methods

add_import(path[, import_path])	Registers a remote file in stage or a local file as an import of a user-defined function (UDF).
add_packages(*packages)	Adds third-party packages as dependencies of a user-defined function (UDF).
add_requirements(file_path)	Adds a requirement file that contains a list of packages as dependencies of a user-defined function (UDF).
call(sproc_name, *args[, statement_params])	Calls a stored procedure by name.
cancel_all()	Cancel all action methods that are running currently.
clear_imports()	Clears all files in a stage or local files from the imports of a user-defined function (UDF).
clear_packages()	Clears all third-party packages of a user-defined function (UDF).
close()	Close this session.
createDataFrame(data[, schema])	Creates a new DataFrame containing the specified values from the local data.
create_async_job(query_id)	Creates an AsyncJob from a query ID.
create_dataframe(data[, schema])	Creates a new DataFrame containing the specified values from the local data.
flatten(input[, path, outer, recursive, mode])	Creates a new DataFrame by flattening compound values into multiple rows.
generator(*columns[, rowcount, timelimit])	Creates a new DataFrame using the Generator table function.
get_current_account()	Returns the name of the current account for the Python connector session attached to this session.
get_current_database()	Returns the name of the current database for the Python connector session attached to this session.
get_current_role()	Returns the name of the primary role in use for the current session.
get_current_schema()	Returns the name of the current schema for the Python connector session attached to this session.
get_current_warehouse()	Returns the name of the warehouse in use for the current session.
get_fully_qualified_current_schema()	Returns the fully qualified name of the current schema for the session.
get_imports()	Returns a list of imports added for user defined functions (UDFs).
get_packages()	Returns a dict of packages added for user-defined functions (UDFs).
get_session_stage()	Returns the name of the temporary stage created by the Snowpark library for uploading and storing temporary artifacts for this session.
query_history()	Create an instance of QueryHistory as a context manager to record queries that are pushed down to the Snowflake database.
range(start[, end, step])	Creates a new DataFrame from a range of numbers.
remove_import(path)	Removes a file in stage or local file from the imports of a user-defined function (UDF).
remove_package(package)	Removes a third-party package from the dependency list of a user-defined function (UDF).
replicate_local_environment([...])	Adds all third-party packages in your local environment as dependencies of a user-defined function (UDF).
sql(query[, params])	Returns a new DataFrame representing the results of a SQL query.
table(name)	Returns a Table that points the specified table.
table_function(func_name, *func_arguments, ...)	Creates a new DataFrame from the given snowflake SQL table function.
use_database(database)	Specifies the active/current database for the session.
use_role(role)	Specifies the active/current primary role for the session.
use_schema(schema)	Specifies the active/current schema for the session.
use_secondary_roles(roles)	Specifies the active/current secondary roles for the session.
use_warehouse(warehouse)	Specifies the active/current warehouse for the session.
write_pandas(df, table_name, *[, database, ...])	Writes a pandas DataFrame to a table in Snowflake and returns a Snowpark DataFrame object referring to the table where the pandas DataFrame was written to.

Attributes

builder	Returns a builder you can use to set configuration properties and create a Session object.
conf
custom_package_usage_config	Get or set configuration parameters related to usage of custom Python packages in Snowflake.
file	Returns a FileOperation object that you can use to perform file operations on stages.
query_tag	The query tag for this session.
read	Returns a DataFrameReader that you can use to read data from various supported sources (e.g.
sproc	Returns a stored_procedure.StoredProcedureRegistration object that you can use to register stored procedures.
sql_simplifier_enabled	Set to True to use the SQL simplifier (defaults to True).
telemetry_enabled	Controls whether or not the Snowpark client sends usage telemetry to Snowflake.
udaf	Returns a udaf.UDAFRegistration object that you can use to register UDAFs.
udf	Returns a udf.UDFRegistration object that you can use to register UDFs.
udtf	Returns a udtf.UDTFRegistration object that you can use to register UDTFs.