在Databricks中使用Python动态地在另一个笔记本中创建一个笔记本



我正在尝试在另一个笔记本中创建一个笔记本,创建的笔记本应该包含python代码和sql代码(使用%sql,%python(。创建后,我需要从父笔记本运行创建的笔记本。有人能提出更好的方法吗。

我发现了类似于dbutils.notebook.run((的东西-这将帮助我运行已经存在的笔记本,但正在寻找一种方法来先创建笔记本,然后再运行它。任何建议都是可观的!!

您可以使用Databricks Workspace REST API的import命令。

类似这样的东西(将笔记本内容放入content值(:

import requests
import os
import json
import base64
ctx = json.loads(dbutils.notebook.entry_point.getDbutils().notebook().getContext().toJson())
host_name = ctx['extraContext']['api_url']
host_token = "your_PAT_token"
notebook_path = ctx['extraContext']['notebook_path']
new_path = os.path.join(os.path.dirname(notebook_path), 'New name')
content = "some code"
data = {
"content": base64.b64encode(content.encode("utf-8")).decode('ascii'),
"path": new_path,
"language": "PYTHON",
"overwrite": True,
"format": "SOURCE"
}
response = requests.post(
'{host_name}/api/2.0/workspace/import',
headers={'Authorization': f'Bearer {host_token}'},
json = data
).json()

相关内容

  • 没有找到相关文章