from snowflake.snowpark import Session
from snowflake.snowpark.functions import col
# Create a new session, using the connection properties specified in a file.
new_session = Session.builder.configs(connection_parameters).create()
# Create a DataFrame that contains the id, name, and serial_number
# columns in the “sample_product_data” table.
df = session.table("sample_product_data").select(
col("id"), col("name"), col("name"), col("serial_number")
)
# Show the results
df.show()
アプリおよび拡張機能を開発する
Snowflakeを拡張し、クライアントとして機能する、または統合コンポーネントとして機能するアプリケーションを記述します。
Snowpark API
SnowparkでPython、Java、Scalaコードを実行する
Snowparkのランタイムとライブラリを使用すると、 SQL 以外のコードを安全に展開して処理し、Snowflakeでパイプライン、 ML モデル、アプリケーションをビルドできます。
ビルド
Python、Java、Scalaなどのネイティブサポートにより、すべてのデータユーザーが単一プラットフォームで作業できるようになります。
セキュア
Forbes Global 2000の500社以上に信頼されている一貫したコントロールをすべてのワークロードに適用する
最適化
Snowflakeデータクラウドを利用して、優れた価格/パフォーマンスとゼロに近いメンテナンスを実現する
Snowparkで多言語を使用してコードを作成する
Snowparkユーザー定義関数(UDFs)とストアドプロシージャを使用して、Python、Java、またはScalaのカスタムコードをSnowflakeで直接実行します。管理、スケール、または操作するクラスターを分ける必要はありません。
Snowparkに挑戦
次のクイックスタートチュートリアルを使用して、Snowparkの実践的な概要を知ることができます。
NATIVE APPS FRAMEWORK
セキュアなデータアプリケーションをビルドする
データと関連するビジネスロジックを他のSnowflakeアカウントと共有して、他のSnowflake機能の能力を拡大する。
FUNCTIONS AND PROCEDURES
Snowflakeの能力を拡張する
プロシージャやユーザー定義関数を記述して、Snowflakeを拡張強化します。いずれの場合も、サポートされているプログラミング言語の1つでロジックを記述します。
KAFKA AND SPARK CONNECTORS
他のシステムと統合する
Snowflakeには、Snowflakeの外部にあるシステムと統合するための APIs を含むコネクタが含まれています。
DRIVERS
ドライバーおよび APIs を使用したクライアントアプリをビルドする
Snowflake操作をクライアントアプリに統合します。Snowpark API に加えて、言語およびプラットフォーム固有のドライバーも使用できます。
ドライバー
ドライバーを使用すると、コードまたはアプリからSnowflakeに接続できます。C#、Go、Pythonなどの言語を使用して、Snowflakeで操作を実行するアプリケーションを記述できます。
RESTful API
Snowflake RESTful SQL API を使用すると、 HTTPS と REST を介してデータにアクセスし、データを更新することができます。たとえば、 SQL ステートメントの送信、ストアドプロシージャの作成と実行、ユーザーのプロビジョニングなどを実行できます。
SQL REST API で、 POST リクエストの本文で実行する SQL ステートメントを送信します。次に、実行ステータスを確認し、 GET リクエストで結果をフェッチします。