【发布时间】:2021-12-10 18:46:44
【问题描述】:
我目前正在编写一个 Scala 代码,该代码可以使用 AD 令牌建立与 SQL 服务器数据库的连接。
网上关于这个主题的文档太少,所以我尝试使用 python 来处理它。现在它正在工作,我希望将我的代码转换为 Scala。
这是python脚本:
context = adal.AuthenticationContext(AUTHORITY_URL)
token = context.acquire_token_with_client_credentials("https://database.windows.net/", CLIENT_ID, CLIENT_SECRET)
access_token = token["accessToken"]
df= spark.read \
.format("com.microsoft.sqlserver.jdbc.spark") \
.option("url", URL) \
.option("dbtable", "tab1") \
.option("accessToken", access_token) \
.option("hostNameInCertificate", "*.database.windows.net") \
.load()
df.show()
【问题讨论】:
标签: scala apache-spark azure-active-directory adal