无法从 Databricks 社区版安装 Azure ADLS Gen 2:com.databricks.rpc.UnknownRemoteException:发生远程异常

问题描述

我正在尝试从我的 databricks 社区版安装 ADLS Gen 2,但是当我运行以下代码时:

test = spark.read.csv("/mnt/lake/RAW/csds.csv",inferSchema=True,header=True)

我收到错误

com.databricks.rpc.UnkNownremoteexception: Remote exception occurred:

我正在使用以下代码安装 ADLS Gen 2

def check(mntPoint):
  a= []
  for test in dbutils.fs.mounts():
    a.append(test.mountPoint)
  result = a.count(mntPoint)
  return result

mount = "/mnt/lake"

if check(mount)==1:
  resultMsg = "<div>%s is already mounted. </div>" % mount
else:
  dbutils.fs.mount(
  source = "wasbs://root@adlspretbiukadlsdev.blob.core.windows.net",mount_point = mount,extra_configs = {"fs.azure.account.key.adlspretbiukadlsdev.blob.core.windows.net":""})
  resultMsg = "<div>%s was mounted. </div>" % mount

displayHTML(resultMsg)


ServicePrincipalID = 'xxxxxxxxxxx'
ServicePrincipalKey = 'xxxxxxxxxxxxxx'
DirectoryID =  'xxxxxxxxxxxxxxx'
Lake =  'adlsgen2'


# Combine DirectoryID into full string
Directory = "https://login.microsoftonline.com/{}/oauth2/token".format(DirectoryID)

# Create configurations for our connection
configs = {"fs.azure.account.auth.type": "OAuth","fs.azure.account.oauth.provider.type": "org.apache.hadoop.fs.azurebfs.oauth2.ClientCredsTokenProvider","fs.azure.account.oauth2.client.id": ServicePrincipalID,"fs.azure.account.oauth2.client.secret": ServicePrincipalKey,"fs.azure.account.oauth2.client.endpoint": Directory}



mount = "/mnt/lake"

if check(mount)==1:
  resultMsg = "<div>%s is already mounted. </div>" % mount
else:
  dbutils.fs.mount(
  source = f"abfss://root@{Lake}.dfs.core.windows.net/",extra_configs = configs)
  resultMsg = "<div>%s was mounted. </div>" % mount

然后我尝试使用以下命令读取 ADLS Gen 2 中的数据帧:

dataPath = "/mnt/lake/RAW/DummyEventData/commercetools/"

test = spark.read.csv("/mnt/lake/RAW/csds.csv",header=True)

com.databricks.rpc.UnkNownremoteexception: Remote exception occurred:

有什么想法吗?

解决方法

根据堆栈跟踪,该错误的最可能原因是您没有为您分配Storage Blob Data Contributor(或Storage Blob Data Reader)角色服务主体(如 documentation 中所述)。这个角色与通常的“贡献者”角色不同,这很令人困惑。

相关问答

Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其...
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。...
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbc...