我有一个具有多个不同阶段的管道,我想做的一件事是在某些点更新 Snowflake 上的表以跟踪管道已达到的位置。
当我尝试运行这个简单的管道时,出现以下错误:
该过程正在执行的操作是从文件中查找一些标头数据,将其存储在变量中,然后尝试使用特定标头列中的标头值更新我们的起始表:
失败的脚本是一个简单的更新:
@concat('update schema.loadcontrol
set fileheader = ',string(variables('RawHeader')),
'where loadnumber = ',variables('LoadNumber'))
如果我删除 RawHeader 变量并将其设置为一个设置值(例如 12345),即使 LoadNumber 也是一个变量,它也可以正常工作。
有谁知道为什么它可能不喜欢 RawHeader 变量,它只是一个标准的 25 个字符的字符串?
它在 Snowflake 上插入的表是 varchar(50),因此有足够的空间。
不知道这是否会带来答案,但当然希望如此。有几件事对我来说很突出:
很想知道它是否有帮助!