如何在ADF管道中创建唯一运行标识，关联SQL Server加载数据？

核心结论 #

完全可以通过SQL生成唯一ID，并在ADF管道的后续步骤中复用这个ID来标记本次运行加载的所有数据。

具体实现步骤 #

1. 在SQL Server中准备生成唯一ID的方式 #

根据需求选择合适的ID生成方案：

方案A：GUID全局唯一标识符

适合不需要有序ID的场景，直接用SQL内置函数生成：

SELECT NEWID() AS RunID;

方案B：有序自增序列

如果需要按运行顺序生成ID，先在SQL Server中创建序列（仅需执行一次）：

CREATE SEQUENCE dbo.LoadRunSeq
    START WITH 1
    INCREMENT BY 1
    MINVALUE 1
    MAXVALUE 999999
    CYCLE;

之后每次生成ID的查询语句：

SELECT NEXT VALUE FOR dbo.LoadRunSeq AS RunID;

2. 在ADF管道中获取生成的ID #

使用ADF的Lookup活动执行上述SQL并提取ID：

• 新建Lookup活动，关联你的SQL Server链接服务
• 在「查询」框中填入生成ID的SQL语句
• 保持「第一行」选项勾选（默认状态），确保只返回单个ID结果

3. 将ID存入管道变量 #

• 在管道中创建一个字符串类型变量（例如var_RunID）
• 添加Set Variable活动，将Lookup返回的ID赋值给变量，表达式为：

  @activity('Lookup_GetRunID').output.firstRow.RunID
  

  注意替换Lookup_GetRunID为你实际的Lookup活动名称

4. 在后续加载步骤中复用ID #

根据你的加载方式传递ID：

• Copy活动映射：在目标表字段映射中，添加静态值并选择var_RunID，映射到目标表的RunID字段
• 存储过程加载：将var_RunID作为参数传入存储过程，在存储过程的插入逻辑中写入目标表
• 自定义SQL插入：直接在插入语句中引用变量，示例：

  INSERT INTO TargetTable (Col1, Col2, RunID)
  SELECT Col1, Col2, '@{variables('var_RunID')}'
  FROM SourceData;
  

注意事项 #

• 确保Lookup活动的SQL仅返回一行数据，避免取值逻辑出错
• 使用序列时，若管道开启重试，重试会生成新ID；如需重试复用同一ID，建议将ID存入管道参数，重试时跳过ID生成步骤
• GUID类型ID需对应SQL Server的UNIQUEIDENTIFIER字段类型，确保目标表字段匹配

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