Databricks ユーティリティ with Databricks Connect for Scala

注記

この記事では、Databricks Runtime13.3LTLTS以降のDatabricks Connectについて説明します。

この記事では、Databricks Connect for Scala で Databricks ユーティリティを使用する方法について説明します。 Databricks Connect を使用すると、一般的な IDEs、ノートブックサーバー、およびカスタムアプリケーションを Databricks クラスターに接続できます。「Databricks Connect とは」を参照してください。この記事の Python バージョンについては、「Databricks ユーティリティと Databricks Connect for Python」を参照してください。

注記

Databricks Connect の使用を開始する前に、 Databricks Connect クライアントを設定する必要があります。

Databricks Connect を使用して Databricks ユーティリティにアクセスするには、次のようにします。

DBUtils.getDBUtils を使用して、Databricks ユーティリティを通じて Databricks ファイルシステム (DBFS) とシークレットにアクセスします。DBUtils.getDBUtils は Databricks Scala ユーティリティライブラリに属しています。
Databricksプロジェクトでは、前述のユーティリティ以外のユーティリティ機能は使用できません。Scala
Databricks Connectfor the は既にScala Databricksユーティリティ forScala ライブラリへの依存関係を宣言しているため、Scala build.sbt``sbt``pom.xmlMavenの、のbuild.gradle 、Gradle のなど、プロジェクトのビルドファイルでこの依存関係を明示的に宣言する必要はありません。
Databricks ユーティリティ for Scala ライブラリの認証は、Databricks Connect プロジェクト内の DatabricksSession0 クラスを Scalaに対して初期化することによって決定されます。

ヒント

また、からのDatabricksSDK JavaScalaDatabricksRESTAPIを使用して、前のDatabricks ユーティリティだけでなく、使用可能な任意のAPIs にアクセスすることもできます。GitHub の databricks/databricks-sdk-java リポジトリと、 Databricks SDK for Java で Scala を使用するを参照してください。

次の例は、 Databricks ユーティリティ for Scala ライブラリを使用して Unity Catalog ボリュームを自動化する方法を示しています。この例では、ワークスペース内のボリュームのパスに zzz_hello.txt という名前のファイルを作成し、ファイルからデータを読み取り、ファイルを削除します。

Scala
import com.databricks.sdk.scala.dbutils.DBUtils

object Main {
  def main(args: Array[String]): Unit = {

    val filePath = "/Volumes/main/default/my-volume/zzz_hello.txt"
    val fileData = "Hello, Databricks!"
    val dbutils = DBUtils.getDBUtils()

    dbutils.fs.put(
      file = filePath,
      contents = fileData,
      overwrite = true
    )

    println(dbutils.fs.head(filePath))

    dbutils.fs.rm(filePath)
  }
}