Azure Data Factory：如何从Data Flow中返回值至调用管道？

方法一：借助数据库临时表中转 #

1. 修改Data Flow：在现有Sink之外，添加一个额外的Sink（指向数据库的临时表，表结构仅需包含存储目标值的单列），将数据流中计算得到的副产品值写入该临时表（确保仅写入一行数据）。
2. 管道添加Lookup活动：在Data Flow活动执行完成后，添加Lookup活动，配置查询语句读取临时表中的目标值（例如SELECT target_column FROM temp_table）。
3. 赋值给管道变量：添加Set Variable活动，将Lookup活动的输出结果（@activity('Lookup活动名称').output.firstRow.target_column）赋值给目标管道变量。
4. 清理临时表（可选）：添加Stored Procedure或Script活动，删除临时表中的数据，避免后续执行出现数据冲突。

方法二：借助文件存储中转 #

1. 修改Data Flow：添加一个额外的Sink，将计算得到的单个值写入Blob存储或ADLS的单个文件（例如格式为单行文本或单键值对的JSON文件）。
2. 管道添加Lookup活动：在Data Flow活动完成后，使用Lookup活动读取该文件的内容。若为文本文件，可通过@activity('Lookup活动名称').output.firstRow.Content获取值；若为JSON文件，可通过对应键名提取。
3. 赋值给管道变量：通过Set Variable活动将提取到的值赋值给目标变量。

注意事项 #

• 确保额外Sink的写入操作不会影响原有数据流的核心逻辑和性能。
• 若使用临时表，需注意权限和并发执行时的数据隔离（例如为每个管道实例生成唯一临时表名）。

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