Databricks 公用程序與適用於 Scala 的 Databricks 連線
注意
本文涵蓋 Databricks 連線 Databricks Runtime 13.3 LTS 和更新版本。
本文說明如何使用 Databricks 公用程式搭配適用於 Scala 的 Databricks 連線。 Databricks 連線 可讓您將熱門 IDE、Notebook 伺服器和自定義應用程式連線至 Azure Databricks 叢集。 請參閱什麼是 Databricks 連線?。 如需本文的 Python 版本,請參閱適用於 Python 的 Databricks 公用程式與 Databricks 連線。
注意
開始使用 Databricks 連線 之前,您必須先設定 Databricks 連線 用戶端。
您可以使用 Databricks 連線 來存取 Databricks 公用程式,如下所示:
- 使用
DBUtils.getDBUtils
透過 Databricks 公用程式存取 Databricks 檔案系統 (DBFS) 和 秘密 。DBUtils.getDBUtils
屬於適用於 Scala 連結庫的 Databricks 公用程式。 - 除了上述公用程式以外,沒有 Databricks 公用程式功能可供 Scala 專案使用。
- 適用於 Scala 的 Databricks 連線 已經宣告對適用於 Scala 的 Databricks 公用程式連結庫的相依性,因此您不需要在 Scala 專案的組建檔案中明確宣告此相依性,例如
build.sbt
sbt
適用於 、pom.xml
適用於 Maven 或build.gradle
Gradle。 - 針對適用於 Scala 的 Databricks 公用程式連結庫進行驗證,是透過
DatabricksSession
初始化適用於 Scala 的 Databricks 連線 專案中的 類別來決定。
提示
您也可以使用來自 Scala 的 Databricks SDK for Java 來存取任何可用的 Databricks REST API,而不只是上述 Databricks 公用程式 API。 請參閱 GitHub 中的 databricks/databricks-sdk-java 存放庫,以及搭配 Databricks SDK for Java 使用 Scala。
下列範例示範如何使用 Databricks Utilities for Scala 連結庫將 Unity 目錄磁碟區自動化。 此範例會在工作區內的磁碟區路徑中建立名為 zzz_hello.txt
的檔案、從檔案讀取數據,然後刪除檔案。
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)
}
}