我已经尝试在我的环境中使用从数据库模板在adf中的增量副本复制带有epoch时间戳类型的水印列。

• 输入表和水位线表如下图所示。（水位线表的初始水位线值为1657238400000，以便在第一次运行时复制所有记录）

• 用于更新新水位线值存储过程是在SQL Server中编写，如以下脚本所示

Create PROCEDURE update_watermark @LastModifyDate numeric(19,0)
AS
BEGIN
    UPDATE watermarktable
    SET [WatermarkValue] = @LastModifyDate
END

• 在ADF中，从数据库模板获取增量副本，并提供源、接收器和控制表的链接服务。然后，选择使用模板。

*LookupLastWaterMark、LookupCurrentWaterMark、DeltaCopyfromDB活动中的配置未更改

• 在UpdateWaterMark活动中，选择存储过程名称，并导入参数。参数LastModifyDate的类型为Int64.
  

• 为管道运行单击Debug，并给出Source、Sink和控制表的管道参数。

• 复制文件后，水印值将更新为最新值。
  

接收器文件：

• 新的行项目被添加到源（下图中的第4条记录是新添加的）。

指令集

• 重新运行管道以检查是否复制了增量行。
  

当epoch时间戳作为水印列给出时，增量记录被复制到接收器。
参考：Delta copy from a database template上的MS文件。