Azure Databricks 中的 dbutils.notebook.run 问题答案

【问题标题】：Troubles with dbutils.notebook.run in Azure DatabricksAzure Databricks 中的 dbutils.notebook.run 问题
【发布时间】：2020-04-08 19:50:26
【问题描述】：

我在尝试执行以下操作时遇到错误。我不知道它可能是什么......

jobStartTime = datetime.strftime(datetime.now(), "%Y-%m-%dT%H:%M:%S%Z")
dbutils.notebook.run("/yptoCommon/LogPowerBI", 60, { "jobStartTime": jobStartTime, "NoteBook": "Oeps", "AllFiles": "10", "ProcessedFiles": "5", "NewRecords": "1" })

我得到的错误是。

com.databricks.WorkflowException: com.databricks.NotebookExecutionException: FAILED --------------------------------------------------------------------------- Py4JJavaError Traceback (most recent call last) <command-4345148969112219> in <module> 1 jobStartTime = datetime.strftime(datetime.now(), "%Y-%m-%dT%H:%M:%S%Z") ----> 2dbutils.notebook.run("/yptoCommon/LogPowerBI", 60, { "jobStartTime": jobStartTime, "NoteBook": "Oeps", "AllFiles": "10", "ProcessedFiles": "5", "NewRecords": "1" })
/local_disk0/tmp/1583836135359-0/dbutils.py in run(self, path, timeout_seconds, arguments, NotebookHandlerdatabricks_internal_cluster_spec) 134 arguments, 135 databricks_internal_cluster_spec, --> 136 self.shell.currentJobGroup) 137 138 def repr_(self):

/databricks/spark/python/lib/py4j-0.10.7-src.zip/py4j/java_gateway.py in call(self, *args) 1255 answer = self.gateway_client.send_command(command) 1256 return_value = get_return_value( -> 1257 answer, self.gateway_client, self.target_id, self.name) 1258 1259 for temp_arg in temp_args:

/databricks/spark/python/pyspark/sql/utils.py in deco(a, *kw)

欢迎任何帮助。

【问题讨论】：

标签： azure azure-databricks

【解决方案1】：

根据我的重复，这是我对上述问题的观察。

如果您在执行笔记本中的任何单元格时遇到任何错误，您将收到此错误消息。您需要修复单元格中的错误并使用“dbutils.notebook.run”来运行笔记本。

示例1：笔记本执行单元格出错

这里我有一个名为“notebook2”的笔记本，它在执行单元格时出现错误消息，如下所示：

当我使用“dbutils.notebook.run”执行笔记本时，我会看到与您相同的错误消息，因为笔记本在执行单元格时出错。

示例 2：成功执行 notebook，没有任何问题

现在回到“notebook2”，我将删除包含错误消息的单元格。

当我使用“dbutils.notebook.run”执行代码时，我将能够成功地运行命令而没有任何问题。

【讨论】：