pyspark - 在 zeppelin 中完成一个进程后，有什么方法可以运行单独的笔记本？

Question

假设以下是示例流程

Notebook1

df.count()
df.show()

Notebook2

df2.count()
df2.show()

Notebook1 完成后，我想在 zeppelin 上调用 Notebook2。

标签： pysparkapache-zeppelin

Answer 1

有两种方法

1. 在notebook1最后一段的末尾，可以调用z.run("", "paragraphid of notebook2");

2. zeppelin 中有一个休息电话（https://zeppelin.apache.org/docs/0.8.1/usage/rest_api/notebook.html#get-the-status-of-a-single-paragraph ），您可以通过它检查段落的状态，例如运行状态或完成。一旦你得到 notebook1 的最后一段的完成状态，你就可以调用 notebook2 的段落。

更多参考：我可以以编程方式检查 Zeppelin 中段落的状态吗？