如何在Azure Data Factory复制活动中参数化查询

问题分析 #

你遇到的两个核心问题：

1. 参数未定义/拼写错误：报错Parameter schema was not found under EX_SourceToRaw_Single_Table，说明你的管道EX_SourceToRaw_Single_Table里没有定义名为schema的参数，或者参数名拼写有误。
2. SQL拼接语法错误：你写的表达式没有用@concat完整包裹整个SQL，还存在多余的括号（比如pipeline().parameters.DeltaTable)多了右括号），导致ADF无法解析。

正确实现步骤 #

1. 确认管道参数已定义 #

在你的管道EX_SourceToRaw_Single_Table中，添加以下字符串类型的参数：

• schema：对应原查询中的Data schema名
• DeltaTable：对应源表名deltaTable
• TargetTable：对应目标表名targetTable

2. 正确的参数化查询表达式 #

用@concat完整拼接整个SQL语句，同时给表设置别名简化写法，避免重复拼接表名：

@concat(
    'SELECT dt.* FROM ',
    pipeline().parameters.schema, '.', pipeline().parameters.DeltaTable, ' dt ',
    'LEFT OUTER JOIN ', pipeline().parameters.schema, '.', pipeline().parameters.TargetTable, ' tt ',
    'ON dt.signature = tt.signature ',
    'WHERE tt.signature IS NULL'
)

3. 表达式说明 #

• 用dt作为源表别名，tt作为目标表别名，避免重复拼接完整表名，让表达式更简洁
• 每个拼接部分用逗号分隔，ADF会自动把所有字符串片段合并成完整SQL
• 注意在表名和别名之间加空格，避免生成的SQL出现语法错误（比如Data.deltaTabledt这种错误）

验证生成的SQL #

当参数值为：

• schema = 'Data'
• DeltaTable = 'deltaTable'
• TargetTable = 'targetTable'

生成的SQL和你原查询一致：

SELECT dt.* FROM Data.deltaTable dt LEFT OUTER JOIN Data.targetTable tt ON dt.signature = tt.signature WHERE tt.signature IS NULL

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