Azure Data Factory参数化复制活动中替换Run_id列值的问题

针对你用ForEach批量处理50+张表、需要替换Run_id同时保留列名的需求，以下是几个可落地的解决方案：

方法1：动态映射（推荐，无需修改数据库架构） #

利用ADF的动态内容自动生成映射，排除源端Run_id并为目标端Run_id赋值新值：

• 先添加一个Lookup活动，连接层2数据库，执行查询获取当前表的列清单：

  SELECT COLUMN_NAME as sourceName FROM INFORMATION_SCHEMA.COLUMNS 
  WHERE TABLE_NAME = '@pipeline().parameters.TableName'
  

• 在复制活动的映射页，切换到代码视图，替换为以下动态JSON：

  {
      "type": "TabularTranslator",
      "mappings": [
          {
              "source": {},
              "sink": {
                  "name": "Run_id",
                  "type": "Expression",
                  "value": "@pipeline().RunId" // 可替换为自定义的Run_id参数
              }
          },
          @json(string(filter(activity('Lookup_Table_Columns').output.value, item() => item().sourceName != 'Run_id')))
      ]
  }
  

  这段代码会自动生成除Run_id外所有列的一对一映射，同时单独为目标Run_id设置新值。
• 在ForEach活动中传入TableName参数，确保每个表都能动态生成对应映射。

方法2：参数化存储过程（灵活可控） #

通过存储过程处理数据插入，直接替换Run_id：

• 在层3数据库创建通用存储过程：

  CREATE PROCEDURE LoadToDataMart
      @TableName NVARCHAR(128),
      @NewRunId NVARCHAR(50)
  AS
  BEGIN
      SET NOCOUNT ON;
      DECLARE @SqlStmt NVARCHAR(MAX);
      -- 构造排除源Run_id、插入新Run_id的语句
      SET @SqlStmt = N'INSERT INTO ' + QUOTENAME(@TableName) + '
                      SELECT * EXCEPT (Run_id), ''' + @NewRunId + ''' AS Run_id
                      FROM [层2数据库名].[dbo].' + QUOTENAME(@TableName);
      EXEC sp_executesql @SqlStmt;
  END
  

• 在ADF ForEach循环中调用存储过程活动，传入当前表名和新Run_id（比如@pipeline().RunId）。
• 注意：需保证层2和层3表结构一致，用QUOTENAME避免SQL注入风险。

方法3：临时重命名源列（快速配置） #

在复制活动源端通过查询临时重命名Run_id，避免自动映射：

• 将复制活动的源数据集查询设为动态内容：

  SELECT * EXCEPT (Run_id) FROM [dbo].[@pipeline().parameters.TableName]
  

• 然后在映射中手动添加Run_id的映射，将目标Run_id设为表达式值（如@pipeline().RunId），其他列保持自动映射即可。
• 这个方法无需额外Lookup活动，配置更简洁，适合快速落地。

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