如何在ADF的后续活动中使用前序Databricks活动的输出结果

1. 操作思路正确性判断 #

你的思路完全正确，将前序Databricks活动的输出添加到第二个Databricks活动的基础参数中，是ADF跨Databricks活动传递数据的标准实现方案。

2. ADF侧参数配置方法 #

在第二个Databricks活动的基础参数配置栏中：

• 自定义参数名（例如prev_activity_output，可自行命名）
• 参数值填写ADF动态表达式：@activity('你前序Databricks活动的实际名称').output.runOutput

3. 第二个Databricks Notebook取值方法 #

你只需要在Notebook代码中通过dbutils.widgets工具即可读取传入的参数，示例代码如下：

import json

# 第一步：声明和ADF配置中同名的参数组件
dbutils.widgets.text("prev_activity_output", "")

# 第二步：读取传入的JSON字符串
output_str = dbutils.widgets.get("prev_activity_output")

# 第三步：解析为JSON对象即可访问对应字段
output_data = json.loads(output_str)

常规场景下上述代码即可正常读取前序活动返回的JSON内容，如果有特殊格式需求可以自行调整解析逻辑。

内容的提问来源于stack exchange，提问作者Shadi