Azure Data Factory动态SQL参数报错：未声明标量变量@的问题排查

我来帮你拆解下问题所在，以及对应的解决办法：

错误原因 #

1. 表达式嵌套语法错误 #

你在@concat()内部使用了@{...}来包裹子表达式，这是ADF表达式的典型误用。因为整个语句已经是以@开头的表达式上下文了，内部的子表达式直接编写即可，不需要再嵌套@{}。这种写法会导致最终生成的SQL语句中出现孤立的@符号，SQL Server会将其视为未声明的标量变量，从而抛出Must declare the scalar variable "@"的错误。

2. 时间计算与格式化语法错误 #

• addhours(pipeline().TriggerTime-24)的写法不符合ADF函数规范：pipeline().TriggerTime是DateTime类型，不能直接做数值减法，必须使用addHours()函数的正确语法：addHours(pipeline().TriggerTime, -24)
• formatDateTime的格式字符串被错误拆分成多个字符串用逗号连接，正确的做法是传入一个完整的格式字符串，比如'yyyy-MM-ddTHH:mm:ssZ'

修正后的表达式 #

@concat(' SELECT * FROM dbo. ', item().TABLE_list , ' WHERE modifieddate > ''', formatDateTime(addHours(pipeline().TriggerTime, -24), 'yyyy-MM-ddTHH:mm:ssZ'), '''')

表达式说明 #

• addHours(pipeline().TriggerTime, -24)：计算本次管道触发时间的24小时前时间（如果你的触发器是每日执行，这就对应上一次运行时间）
• formatDateTime(..., 'yyyy-MM-ddTHH:mm:ssZ')：将时间格式化为SQL Server可识别的UTC标准格式
• ''：用于转义SQL语句中的单引号，确保生成的SQL中时间值被正确包裹（最终生成的SQL类似modifieddate > '2024-05-20T10:00:00Z'）

额外补充 #

如果你的需求是获取管道上一次实际成功运行的时间（而非当前触发时间减24小时，比如触发器有延迟或执行频率不固定），你需要通过ADF的Lookup活动查询管道运行历史（借助Azure Monitor的日志或ADF的REST API）来获取该时间值，再传入SQL语句中。

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