惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

B
Blog RSS Feed
J
Java Code Geeks
H
Help Net Security
Google DeepMind News
Google DeepMind News
博客园 - 司徒正美
Microsoft Security Blog
Microsoft Security Blog
宝玉的分享
宝玉的分享
Stack Overflow Blog
Stack Overflow Blog
D
DataBreaches.Net
The GitHub Blog
The GitHub Blog
S
SegmentFault 最新的问题
U
Unit 42
博客园 - 三生石上(FineUI控件)
Last Week in AI
Last Week in AI
M
MIT News - Artificial intelligence
WordPress大学
WordPress大学
小众软件
小众软件
博客园 - 叶小钗
D
Docker
量子位
P
Proofpoint News Feed
博客园_首页
T
Tailwind CSS Blog
F
Fortinet All Blogs

jdhao's digital space

Conversion between base64 and OpenCV or PIL Image 腾讯云对象存储博客图床开启 CDN 加速(不需要购买额外域名) Search and Replace in Multiple Files in Vim/Neovim Change Table Column Width in LaTeX Image or Table Side by Side in LaTeX LaTeX 并排显示图像或表格 Firenvim: Neovim inside Your Browser Content inside HTML tags missing in Latest Hugo? Creating Markdown Front Matter with Ultisnips Labelme JSON 标注格式转 voc XML 格式 Nifty Nvim Techniques That Make My Life Easier -- Series 6 macOS 下如何为视频制作字幕 Running Command Asynchronously inside Neovim Resolving Merge Conflict after Git Stash Pop Pylint: command not found? A Hands-on Experience with Neovim's Built-in LSP Support How to Convert PDF to Images with Imagemagick 互联网上常用缩略语集锦 File Backup in Neovim Converting PDF Pages to Images with Poppler Nifty Nvim Techniques That Make My Life Easier -- Series 5 Neovim Configuration for System-wide Use How to sort a list of tuple or list in Python -- lambda or itemgetter? Building A Vim Statusline from Scratch 人类第一颗原子弹爆炸始末 Distributed Training in PyTorch with Horovod Learning Expect Programming Essential Knowledge about SSH Nifty LaTeX Techniques -- Series 1 更改 Adsense 邮寄地址,重新寄送 PIN
Working with Databricks Workspace Files
2023-11-19 · via jdhao's digital space

Some observation and finding in working with Databricks workspace files.

How to read/access workspace files#

For regular Python#

The behavior to access the workspace file is also different based on the databricks runtime (abbreviation, DBR) version. For the following code:

with open('/Workspace/Users/<user-email>/path/to/file') as f:
    content = f.readlines()

print(content)

In DBR 10.4, I get the following error:

FileNotFoundError: [Errno 2] No such file or directory: ‘/Workspace/Users//path/to/file’

Since DBR 11.3, we can access the files under the databricks workspace using their absolute paths (source here). So the above code should work as expected to print the file content. However, this does not apply to the notebooks under the workspace (source here). I think this is fine, because most people don’t have such needs to read notebooks directly.

Since DBR 14.0, as discussed later, the current working directory is changed to the folder where the notebook is run. So you can additionally use relative path to access workspace files. For example, if there is test.py in the folder as the notebook, you can run the following code without error:

with open('./test.py', 'r') as f:
    content = f.readlines()
print(content)

For spark code#

For spark code, it is also possible to access the workspace files. However, there are two requirements:

  • you must use the fully-qualified path for the workspace files, e.g., the path should be something like file:/Workspace/Users/<user-name>/<folder-name>/MOCK_DATA.csv
  • the cluster can’t be in shared access mode, otherwise, you will see the following error when trying to access the workspace files:

    java.lang.SecurityException: Cannot use com.databricks.backend.daemon.driver.WorkspaceLocalFileSystem - local filesystem access is forbidden

If both condition is satisfied, you should be able to run the following code without error:

df = spark.read.csv("file:/Workspace/Users/<user-name>/<folder-name>/MOCK_DATA.csv", header=True)
display(df)

comparison#

yeah, databricks just makes things f*king complicated. I am scratching my hair out trying to figuring out these complicated rules and cases. Here is a comparison table (hopefully it makes it easier to understand):

DBR versionsopen() with absolute pathopen() with relative pathspark.read with absolute pathspark.read with relative path
DBR 11.3 single usernot supported, cwd is not workspace folder❌, path must be absolute
DBR 11.3 sharednot supported, cwd is not workspace folder❌, path must be absolute
DBR 14.1 single user❌, path must be absolute
DBR 14.1 shared❌, path must be absolute

ref:

Current working directory#

In the old DBR, when you run the Python code, the current working directory is /databricks/driver. To check the DBR version and your current working directory, use this:

import os

print(spark.conf.get("spark.databricks.clusterUsageTags.sparkVersion"))
print(os.path.abspath('./'))

In my DBR 10.4 (single user access mode, the directory is different if you use shared access mode), I see the following output:

10.4.x-scala2.12
/databricks/driver

Starting in databricks 14.0, the current working directory is changed to the directory where the notebook runs (source here). In DBR 14.1 cluster, I see the following output:

14.1.x-scala2.12
/Workspace/Users/<user-email>/<current-folder-name>

You can use relative path to write and read file, but their location is different in different DBR. For example, for the following code:

with open('./demo.txt', 'w') as f:
    f.write("hello world\n")

If you use 10.4, the file is saved in /databricks/driver/demo.txt, under the driver node. If you use 11.3, the file is saved in /home/spark-<some-random-string>/demo.txt If you use 14.1, the file is saved in /Workspace/<user-email>/<current-folder>/demo.txt.

ref: