其目标是从ADLS挂载点以字节字符串的形式在Databricks中读取文件。

确认ADLS挂载点

首先，使用dbutils.fs.mounts()确认具有以下内容：

... MountInfo(mountPoint='/mnt/ftd', source='abfss://ftd@omitted.dfs.core.windows.net/', encryptionType=''), ...

确认文件存在

有问题的文件名为TruthTable.csv，已使用以下命令确认其下落：

dbutils.fs.ls('/mnt/ftd/TruthTable.csv')

它返回：

[FileInfo(path='dbfs:/mnt/ftd/TruthTable.csv', name='TruthTable.csv', size=156)]

确认文件可读性

要确认该文件是否可读，我们可以运行以下代码片段。

filePath = '/mnt/ftd/TruthTable.csv'
spark.read.format('csv').option('header','true').load(filePath)

它成功地返回

DataFrame[p: string, q: string, r: string, s: string]

问题所在

因为目标是能够以字节字符串的形式读取文件，所以下面的代码片段应该是成功的，然而，它不是。

filePath = '/mnt/ftd/TruthTable.csv'
with open(filePath, 'rb') as fin:
  contents = fin.read()
  print(contents)

执行以下代码段输出：

FileNotFoundError: [Errno 2] No such file or directory: '/mnt/ftd/TruthTable.csv'

数据库团队在以下链接[https://docs.databricks.com/data/databricks-file-system.html#local-file-apis][https://docs.databricks.com/data/databricks-file-system.html#local-file-apis]上提供的文档仅适用于/tmp/文件夹中的文件，但要求直接从挂载点读取文件。