如何获取Copy Activity写入Sink的记录以执行更新操作

这里提供几种实用方法，帮你定位刚插入Azure SQL表的记录并执行更新：

方法一：用业务唯一主键追踪 #

如果REST API返回的数据自带唯一业务主键（比如订单ID、用户ID这类不会重复的值），这是最直接的方式：

• 先把本次要插入的所有主键暂存起来：可以用Lookup Activity先调用API获取主键集合，或者在Copy时同步把主键写入一个临时表。
• 插入完成后，在SQL Activity里执行更新语句：

  UPDATE 目标表 
  SET 字段1 = 值1, 字段2 = 值2
  WHERE 主键字段 IN (SELECT 主键 FROM 临时表)
  

方法二：新增插入时间戳字段 #

给目标表加一个时间戳字段，用来标记每条记录的插入时间：

1. 先修改表结构：

   ALTER TABLE 你的目标表 ADD InsertedAt DATETIME DEFAULT GETUTCDATE();
   

2. 执行Copy Activity时，要么让数据库自动填充默认值，要么在Sink映射里手动给InsertedAt赋值为当前UTC时间。
3. 插入完成后，记录下本次操作的时间范围（用Set Variable Activity获取当前时间），然后执行更新：

   UPDATE 你的目标表 
   SET ... 
   WHERE InsertedAt >= @variables('本次插入起始时间') AND InsertedAt <= @variables('本次插入结束时间')
   

• 注意：如果Copy执行时间较长，要确保时间范围能精准覆盖本次插入的所有记录，避免包含其他并发插入的数据。

方法三：临时表中转 #

通过临时表作为中间层，确保只操作本次插入的数据集：

1. 用Copy Activity把API返回的数据先写入临时表（比如#TempData，如果需要跨Activity持久化就用普通中转表）。
2. 把临时表的数据插入目标表：

   INSERT INTO 目标表 SELECT * FROM #TempData
   

3. 直接关联临时表执行更新：

   UPDATE t 
   SET t.字段 = td.字段
   FROM 目标表 t
   JOIN #TempData td ON t.主键字段 = td.主键字段
   

• 这种方法完全隔离了本次插入的数据，不会受其他并发操作干扰，适合数据量较大或并发场景。

方法四：结合Copy Activity输出属性 #

Copy Activity执行后会输出output.rowsCopied（插入行数），但这个只能知道数量，没法直接拿到具体记录。不过如果API支持按参数过滤（比如按请求时间、批次ID），可以在调用API时带上唯一批次标识，把这个标识同步插入目标表，之后用批次ID作为更新条件。

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