azure-data-factory - 如何在 ADF 内的未来活动中使用 Databricks 活动的输出？

Question

我在 ADF 中有一个 Databricks 活动，并使用以下代码传递输出：

 dbutils.notebook.exit(message_json)

现在，我想将此输出用于下一个 Databrick 活动。

作为我的搜索，我认为将最后一个输出添加到第二个活动的基本参数中。我对吗？

和其他问题，如何在 Databrick 笔记本中使用此输出？

编辑：输出是一个 JSON，如下图所示。

标签： azure-data-factoryazure-databricks

Answer 1

根据文档，您可以使用诸如@{activity('databricks notebook activity name').output.runOutput}.

如果您传递 JSON 对象，您可以通过附加属性名称来检索值。

示例：@{activity('databricks notebook activity name').output.runOutput.PropertyName}。

我重现了这个问题，它工作正常。

下面是示例笔记本。

import json
dates = ['2017-12-11', '2017-12-10', '2017-12-09', '2017-12-08', '2017-12-07']
return_json = json.dumps(dates)
dbutils.notebook.exit(return_json)

这是 Notebook2 Activity Seeting 的样子：

管道成功运行。