python - 如何使用 REST api 运行 zeppelin 笔记本并在 python 中返回结果？

Question

我正在使用来自 python 的以下 REST 调用运行 zeppelin 笔记本:

导入请求
requests.post('http://x.y.z.x:8080/api/notebook/job/2BZ3VJZ4G').json()

输出为 {u'status': u'OK'}

但我想将 zeppelin 笔记本中的几个 block 的一些结果/异常(如果有)返回到 python 脚本。

我还尝试使用

仅运行笔记本中的一个段落

requests.post('http://x.y.z.x:8080/api/notebook/job/2BZ3VJZ4G/20160922-140926_526498241').json()

并收到相同的输出 {u'status': u'OK'}。

有人可以帮我在 python 中检索 zeppelin 的结果吗？

Answer 1

Zeppelin 在其最新尚未发布的 0.7.0 版本中引入了同步 API 来运行段落。您可以从他们的存储库克隆最新代码并自己构建快照。 API 的 URL 为 http://[zeppelin-server]:[zeppelin-port]/api/notebook/run/[notebookId]/[paragraphId] 。这将在段落完全运行后返回输出。