Snowpark Scala用Scala REPL の設定

このトピックでは、Snowpark用Scala REPL を設定する方法について説明します。

このトピックの内容:

Java REPL のインストール

Scala REPL （read-eval-printループ）は、Scalaビルドツールで提供されます。 サポートされているScalaビルドツールのバージョン をインストールするには、 使用する予定のバージョン を見つけて、インストール手順に従います。

Scala REPL の実行

Scala REPL でSnowparkライブラリを使用するには、

  1. まだ実行していない場合は、 Snowparkライブラリアーカイブファイルをダウンロードして、ファイルの内容を抽出 します。

  2. アーカイブファイルで提供されている run.sh シェルスクリプトを実行して、 REPL を開始します。

cd <path>/snowpark-1.10.0
./run.sh

run.sh スクリプトは、次を実行します。

  • Snowparkライブラリと依存関係をクラスパスに追加します。

  • Scala REPL によって生成されたクラスの <パス>/snowpark-1.10.0/repl_classes/ ディレクトリを作成します。

  • com.snowflake.snowpark パッケージと com.snowflake.snowpark.functions オブジェクトをインポートする preload.scala ファイルをプリロードします。

Scalaに別の REPL を使用している場合は、

  1. Snowparkライブラリ JAR ファイルと依存関係をクラスパスに追加します。

    • Snowparkライブラリの JAR ファイルは、抽出された TAR/ZIP アーカイブファイルの最上位ディレクトリにあります。

    • 依存関係は、抽出された TAR/ZIP アーカイブファイルの lib ディレクトリにあります。

  2. REPL によって生成されたクラスの仮ディレクトリを作成し、そのディレクトリにクラスを生成するように REPL を構成します。

後で、インラインユーザー定義関数（UDFs）を定義するときに、 依存関係として REPL クラスのディレクトリを指定 する必要があります。

Scala REPL 構成の確認

Snowparkを使用するようにプロジェクトを構成したことを確認するには、Snowparkコードの簡単な例を実行します。

  1. .zip / .tar.gz ファイルから抽出されたファイルを含むディレクトリ（つまり、 run.sh スクリプトを含むディレクトリ）に、以下のコードを含む Main.scala ファイルを作成します。

    import com.snowflake.snowpark._
import com.snowflake.snowpark.functions._

object Main {
  def main(args: Array[String]): Unit = {
    // Replace the <placeholders> below.
    val configs = Map (
      "URL" -> "https://<account_identifier>.snowflakecomputing.com:443",
      "USER" -> "<user name>",
      "PASSWORD" -> "<password>",
      "ROLE" -> "<role name>",
      "WAREHOUSE" -> "<warehouse name>",
      "DB" -> "<database name>",
      "SCHEMA" -> "<schema name>"
    )
    val session = Session.builder.configs(configs).create
    session.sql("show tables").show()
  }
}
    Copy

    次の点に注意してください。

    • <プレースホルダー> をSnowflakeへの接続に使用する値に置き換えます。

    • <アカウント識別子> には、使用する アカウント識別子 を指定します。

    • キーペア認証 を使用する場合は、

      • PASSWORD を PRIVATE_KEY_FILE に置き換え、秘密キーファイルへのパスに設定します。

      • 秘密キーが暗号化されている場合は、秘密キーを復号化するためのパスフレーズに PRIVATE_KEY_FILE_PWD を設定する必要があります。

      PRIVATE_KEY_FILE と PRIVATE_KEY_FILE_PWD を設定する代わりに、 PRIVATEKEY プロパティを秘密キーファイルからの 暗号化されていない 秘密キーの文字列値に設定できます。

      • たとえば、秘密キーファイルが暗号化されていない場合は、これをファイル内のキーの値に設定します（-----BEGIN PRIVATE KEY----- と -----END PRIVATE KEY----- ヘッダーとフッターなし、行末なし）。

      • 秘密キーが暗号化されている場合は、 PRIVATEKEY プロパティの値として設定する前に、キーを復号化する必要があることに注意してください。

  2. ディレクトリ内から、 run.sh スクリプトを実行して、Snowparkライブラリに必要な設定でScala REPL を起動します。

    ./run.sh
    Copy

  3. Scala REPL シェルで次のコマンドを入力して、作成したサンプルファイルをロードします。

    :load Main.scala
    Copy

  4. 次のステートメントを実行して、ロードしたクラスの main メソッドを実行します。

    Main.main(Array[String]())
    Copy

    これにより、 SHOW TABLES コマンドが実行され、結果の最初の10行が出力されます。

言語: 日本語