使用workspace api导入方法导入databricks notebook（动态内容）答案

【问题标题】：Import databricks notebook (dynamic content) using workspace api import method使用workspace api导入方法导入databricks notebook（动态内容）
【发布时间】：2021-12-26 16:01:46
【问题描述】：

我想使用工作区 api 导入方法导入 databricks 笔记本。笔记本的内容应该是动态的。我正在尝试使用下面的代码，但它给出了错误：

请求错误

请求包含无效的 json 正文。我已经尝试将content 转换为base64 编码数据并将其传递到有效负载中，但它仍然给出相同的错误。我想要实现的主要目标是，我想动态生成笔记本的内容。

import requests
import os
import json

ctx = json.loads(dbutils.notebook.entry_point.getDbutils().notebook().getContext().toJson())
host_name = ctx['extraContext']['api_url']
host_token = ctx['extraContext']['api_token']
notebook_path = ctx['extraContext']['notebook_path']
new_path = os.path.join(os.path.dirname(notebook_path), 'New name')

data = {
  "content": "print(hellow world)",
  "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}'},
    data = data
  ).json()

【问题讨论】：

标签： python azure-databricks

【解决方案1】：

这里有几个问题：

根据documentation，content 字段应该是 base64 编码的，所以你需要这样做：

import base64
data = {
  "content": base64.b64encode("print(hellow world)".encode()),
  ...
}

有效负载应该是 JSON，但您使用 data 参数将数据作为多部分表单数据发送（请参阅 docs）。您需要改用json 参数：

response = requests.post(
    f'{host_name}/api/2.0/workspace/import',
    headers={'Authorization': f'Bearer {host_token}'},
    json = data
  ).json()

您正在尝试替换主机名，但您使用的只是字符串，而不是 f 字符串，因此您需要将 '{host_name}/api/2.0/workspace/import' 更改为 f'{host_name}/api/2.0/workspace/import'

【讨论】：