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

Question

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

 dbutils.notebook.exit(message_json)

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

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

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

已编辑：输出为 JSON，如下图所示。

Answer 1

根据doc，您可以使用@{activity('databricks notebook activity name').output.runOutput}等表达式来消费数据工厂中Databrick Notebook活动的输出。

如果您传递 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 的样子：

管道运行成功。