如何获取Azure Data Factory数据流中Exists活动结果的行数？

问题解答 #

1. 如何获取Exists活动结果的行数？ #

Exists活动仅返回布尔值（true/false），用于标识是否存在匹配项，不会直接输出结果集行数。要获取实际匹配记录的行数，需要通过额外的活动或转换逻辑捕获计数结果。

2. Azure Data Factory是否有内置函数或表达式可实现此需求？ #

ADF内置表达式无法直接从Exists活动提取行数，因为Exists的输出仅包含exists状态字段。但可以用表达式读取其他计数活动的输出，比如通过@activity('<ActivityName>').output.count读取Lookup活动返回的记录总数，或@activity('<LookupActivity>').output.firstRow.match_count读取自定义统计的匹配行数。

3. 是否需要添加额外活动或转换来捕获行数，若需要应选择哪些？ #

需要添加额外活动或转换，推荐两种实用方案：

• 方案一：Lookup活动直接统计
  配置Lookup活动，编写关联查询直接对比SQL表和Blob CSV的数据并统计匹配行数，示例SQL查询：

  SELECT COUNT(*) AS match_count 
  FROM YourSQLTable t
  JOIN OPENROWSET(BULK 'your-blob-path', FORMAT = 'CSV') csv
  ON t.id = csv.id
  

  执行后，通过表达式@activity('Lookup_MatchCount').output.firstRow.match_count即可获取行数，后续活动可直接引用该值。
• 方案二：数据流聚合转换
  在现有比对数据流中添加聚合转换，使用count()函数统计所有匹配记录的数量，将聚合结果写入临时SQL表或Blob文件；之后用Lookup活动读取临时存储的计数结果，传递给后续管道活动。

如果已用Exists活动做基础校验，可设置分支逻辑：仅当Exists返回true时，再触发上述计数活动，避免无效计算。

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