How can I read data from a Snowflake table into a Snowpark DataFrame?

There are a few ways to read data from a Snowflake table into a Snowpark DataFrame.

• Using the readTable() method: This method is available in the Snowpark API for each supported programming language. It takes a few parameters, such as the name of the table and the database in which the table resides.
• Using the sql() method: This method is also available in the Snowpark API for each supported programming language. It takes a SQL query as its parameter. The SQL query can be used to select data from one or more tables.
• Using the Snowpark SparkSession: If you are using Snowpark with Spark, you can read data from a Snowflake table by using the Snowpark SparkSession. This class provides a number of convenience methods for reading data from Snowflake tables.

Here is an example of how to read data from a Snowflake table into a Snowpark DataFrame using the readTable() method in Python:

Python

from snowflake.snowpark import Session
from snowflake.snowpark import DataFrame

session = Session.builder().account("myaccount").user("myuser").password("mypassword").build()

df = session.readTable("mytable", "mydatabase")

Use code with caution. Learn morecontent_copy

Here is an example of how to read data from a Snowflake table into a Snowpark DataFrame using the sql() method in Python:

Python

from snowflake.snowpark import Session
from snowflake.snowpark import DataFrame

session = Session.builder().account("myaccount").user("myuser").password("mypassword").build()

df = session.sql("SELECT * FROM mytable")

Use code with caution. Learn morecontent_copy

Here is an example of how to read data from a Snowflake table into a Snowpark DataFrame using the Snowpark SparkSession in Scala:

Scala

import com.snowflake.snowpark._
import com.snowflake.snowpark.spark._

val session = SnowparkSession.builder()
  .account("myaccount")
  .user("myuser")
  .password("mypassword")
  .build()

val df = session.readTable("mytable", "mydatabase")

Use code with caution.

Once you have read data into a Snowpark DataFrame, you can use it to perform a variety of data processing tasks, such as filtering, sorting, aggregating, and joining.