使用Python SDK dbfs文件導入到工作區中

[kurtrm]

你好,

我想複製提供的功能使用Python SDK databricks_cli Python包。之前,使用databricks_cli WorkspaceApi對象,我可以用import_workspace或import_workspace_dir方法將Python文件,SQL文件,或工作區目錄。我不確定如何使用SDK。我已經嚐試了以下的組合:

從磚進口操作係統。sdk進口WorkspaceClient進口磚。sdk從zipfile進口zipfile進口io prod_w = WorkspaceClient(主機= dbutils.notebook.entry_point.getDbutils () .notebook () .getContext () .apiUrl () . get(),令牌= dbutils.notebook.entry_point.getDbutils () .notebook () .getContext () .apiToken () . get())下= prod_w.dbfs.download (/ FileStore / tmp / my_file.py) #試試這個?prod_w.workspace.import_(' /用戶/(電子郵件保護)/ my_file’,內容=,= databricks.sdk.service.workspace.ImportFormat格式。汽車、語言= databricks.sdk.service.workspace.Language。PYTHON,覆蓋= True) #或嗎?prod_w.workspace.upload(' /用戶/(電子郵件保護)/ my_file’,內容=,= databricks.sdk.service.workspace.ImportFormat格式。汽車、語言= databricks.sdk.service.workspace.Language。PYTHON,覆蓋= True)

我得到錯誤的ImportFormat參數或參數提供內容。如果我讓它工作,文件是空的。

請不要讓太在上麵的代碼的細節;我隻是盡我最大努力提供一些實實在在的例子,我想做的事:一個有效dbfs文件導入工作區使用磚Python的SDK。我希望在SDK可以提供一個更有見識的人的例子,我想做什麼工作。

謝謝你！

庫爾特

[Atanu]

你有試過檢查https://docs.m.eheci.com/dev-tools/sdk-python.html嗎?

https://github.com/databricks/databricks-sdk-py

[kurtrm]

嗨Atanu,

謝謝你的回複。GitHub回購中提供的例子是有用的但不是比中提供的不同文檔。目前尚不清楚上傳和import_方法之間的區別是什麼……

[Atanu]

你麵臨的問題是什麼?錯誤消息分享我們可以檢查嗎?

[Kratik]

甚至,我正在尋找一種方式把文件現在在S3中以編程方式工作區。