我们如何在 Azure Databricks 中使用 Active Directory 身份验证连接 Azure SQL 数据库

Question

如何在此处显示的代码中将 AAD 会话值放在密码和用户名上：

    import com.microsoft.azure.sqldb.spark.config.Config
    import com.microsoft.azure.sqldb.spark.connect._

    val config = Config(Map(
      "url"            -> "kkk-server.database.windows.net:1433",
      "databaseName"   -> "MyDatabase",
      "dbTable"        -> "dbo.Clients",
      "user"           -> "AD-account",
      "password"       -> "xxxxxxxx",
      "connectTimeout" -> "5", //seconds
      "queryTimeout"   -> "5"  //seconds
    ))

    val collection = spark.read.sqlDB(config)
    collection.show()

Answer 1

您可以在 Azure Databricks 中使用 Spark connector for SQL Server and Azure SQL Database。

用于 SQL Server 和 Azure SQL 数据库的 Spark 连接器还支持 Azure Active Directory (AAD) 身份验证。它允许您使用您的 AAD 帐户从 Azure Databricks 安全地连接到您的 Azure SQL 数据库。它提供了类似于内置 JDBC 连接器的接口。

示例如下：

import com.microsoft.azure.sqldb.spark.config.Config
import com.microsoft.azure.sqldb.spark.connect._

val config = Config(Map(
  "url"            -> "mysqlserver.database.windows.net",
  "databaseName"   -> "MyDatabase",
  "user"           -> "username ",
  "password"       -> "*********",
  "authentication" -> "ActiveDirectoryPassword",
  "encrypt"        -> "true"
))

val collection = sqlContext.read.SqlDB(config)
collection.show()

更多详情请见：Connect Spark to Azure SQL Database using AAD authentication

希望这会有所帮助。

Answer 2

目前无法使用 Azure Active Directory (AAD) 身份验证连接到 Azure Databricks 上的 Azure SQL 数据库。您应该使用 SQL 身份验证。

如果您在 Azure Databricks 上尝试 AAD 身份验证，您可能会收到错误“此驱动程序未配置为集成身份验证”或类似错误消息。

虽然可以在 Azure Data Lake 中使用 AAD。