如何使用Python Flask Api触发Databricks Notebook？

Question

我想从我的本地VS代码中运行的flask api函数触发我的azure账户中的Databricks notebbok。我有所有的连接参数，如主机URL，cluster_id，Token_id，除了Org_id，我无法找到和笔记本的路径。如何写一个Flask Api来基本上触发（运行）该Databricks Notebook。

Answer 1

你可以通过Flask API调用Databricks Rest API，如下所示。

headers = {
    'Authorization': 'Bearer <token_id>',
    'content-type': 'application/json'
}
di={"job_id":int(job),"notebook_params":{"id":str(id)}} //Databricks paramters

resp = requests.post('<Databricks Workspace URL>/api/2.0/jobs/run-now', headers=headers, data=json.dumps(data))

你可以在databricks的Job标签页中获取job id。