Snowparkの IntelliJ IDEA CE の設定

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

このトピックの内容:

Scala開発用 IntelliJ IDEA CE の設定

IntelliJ IDEA CE でScalaを使用するには、Scalaプラグインをインストールする必要があります。チュートリアル IntelliJ IDEA でScalaを始めるインストールセクション をご参照ください。

IntelliJ IDEA での新しいScalaプロジェクトの作成

次に、Snowpark用の新しいScalaプロジェクトを作成します。

  1. File » New » Project を選択します。

    1. 左側のリストで、Scalaを選択します。

    2. 右側のリストで、sbtを選択します。

      Window for selecting the type of project to create
    3. Next をクリックします。

  2. 新しいプロジェクトの詳細を入力します。

    JDK とScala SDK の場合は、 Snowparkでの使用がサポートされている JDK およびScalaのバージョン を選択します。

  3. Finish をクリックして新しいプロジェクトを作成します。

Snowpark用 IntelliJ IDEA プロジェクトの構成

次に、Snowpark用プロジェクトを構成します。

左側 にある Project ツールウィンドウで、プロジェクトの build.sbt ファイルをダブルクリックします。

プロジェクトの build.sbt ファイルで、次を変更します。

  1. scalaVersion 設定が使用する予定のバージョンと一致しない場合は、設定を更新します。例:

    scalaVersion := "2.12.13"
    

    Snowparkライブラリとの使用がサポートされているScalaバージョン を使用する必要があることに注意してください。

  2. OSGEO リリースリポジトリをリゾルバーのリストに追加し、Snowparkライブラリを依存関係のリストに追加します。例:

    resolvers += "OSGeo Release Repository" at "https://repo.osgeo.org/repository/release/"
    libraryDependencies += "com.snowflake" % "snowpark" % "0.6.0"
  3. build.sbt ファイルへの変更を保存します。

  4. SBT プロジェクトをリロードします。

    1. View » Tool Windows » sbt を選択して、 sbt Tool ウィンドウを表示します。

    2. プロジェクト名を右クリックして、 Reload sbt Project を選択します。

    これにより、 IntelliJ IDEA CE はSnowparkライブラリをダウンロードし、コードで API を使用できるようになります。

IntelliJ IDEA プロジェクト構成の確認

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

  1. 左側 にある Project ツールウィンドウで、プロジェクトを展開し、 src/main フォルダーを展開して、 scala フォルダーを選択します。

  2. フォルダーを右クリックして、 New » Scala class を選択します。

  3. Create New Scala Class ダイアログボックスで、名前「Main」を入力し、 Object を選択して、Enterキーを押します。

  4. 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()
      }
    }
    

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

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

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

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

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

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

      PRIVATE_KEY_FILE を設定する代わりに、 PRIVATEKEY プロパティを秘密キーファイルの秘密キーの値に設定できます。 -----BEGIN ... PRIVATE KEY----- 行と -----END ... PRIVATE KEY----- 行、およびキャリッジリターンとラインフィードを削除する必要があることに注意してください。

    • UDFs を作成する場合は、

  5. Object 行の横にある緑色の矢印をクリックし、 Run Main を選択して例を実行します。

    Arrow icon for running the sample program