如何通过Zeppelin REST API传参执行多段落笔记任务？

1. 核心思路 #

你需要先调用REST API执行带参数的目标段落（这个段落负责接收并存储参数到Zeppelin上下文），再触发后续依赖该参数的段落执行，这样后续段落就能直接读取上下文里的参数了。

2. 步骤详解 #

第一步：配置接收参数的段落 #

在你的Zeppelin笔记中，专门设置一个段落（比如段落ID为20240520-143000_123456），用来接收API传入的参数并存入Zeppelin全局上下文：

// 接收API传递的参数，默认值作为兜底
val filename = z.get("filename").getOrElse("/default/path.txt")
val threshold = z.get("threshold").map(_.toDouble).getOrElse(0.5)

// 将参数存入上下文，供后续所有段落复用
z.put("input_filename", filename)
z.put("filter_threshold", threshold)

第二步：通过REST API提交带参数的段落请求 #

使用curl调用Zeppelin的段落执行API，把参数放在请求体的params字段中。记得替换成你自己的Zeppelin服务地址、笔记ID和目标段落ID：

curl -H "Content-Type: application/json" \
     -X POST \
     -d '{
           "params": {
             "filename": "/myfolder/my_file.txt",
             "threshold": "0.8"
           },
           "run": true
         }' \
     http://your-zeppelin-server:8080/api/notebook/2B8F5E9A123456/paragraph/20240520-143000_123456/execute

• your-zeppelin-server:8080：替换为你的Zeppelin服务地址和端口
• 2B8F5E9A123456：替换为你的笔记ID（可从笔记URL中提取）
• 20240520-143000_123456：替换为你用来接收参数的段落ID

第三步：执行后续依赖段落 #

等参数段落执行完成后，再调用API触发后续需要用到参数的段落。比如后续段落ID为20240520-144000_789012：

curl -X POST \
     http://your-zeppelin-server:8080/api/notebook/2B8F5E9A123456/paragraph/20240520-144000_789012/execute

这个段落里可以直接读取上下文里的参数：

// 读取上下文存储的参数
val inputFile = z.get("input_filename").get
val threshold = z.get("filter_threshold").get.toDouble

// 业务逻辑示例
println(s"开始处理文件: $inputFile，过滤阈值: $threshold")

3. 进阶：批量执行段落（可选） #

如果需要一次性触发参数段落+后续多个段落，可以先调用参数段落的执行API，通过GET请求查询其执行状态，等状态变为FINISHED后再依次触发后续段落：

# 查询段落执行状态
curl http://your-zeppelin-server:8080/api/notebook/2B8F5E9A123456/paragraph/20240520-143000_123456

返回结果中的status字段会显示段落状态（RUNNING/FINISHED/ERROR），确认完成后再执行后续段落即可。

4. 注意事项 #

• 若Zeppelin启用了认证，需要在curl命令中添加-u username:password参数进行身份验证
• API传递的参数默认都是字符串类型，后续段落需要自行转换为对应的数据类型（如数字、布尔值）
• 段落ID和笔记ID可以在Zeppelin网页端的段落菜单（右上角三个点）中查看，或直接从页面URL提取

内容的提问来源于stack exchange，提问作者florins