在 Azure 数据工厂中使用动态日期筛选器查询 SQL table(Azure 突触分析)

querying of SQL table with dynamic date filter in Azure data factory (Azure synapse analytics)

如何将日期时间参数传递给 ADF/synapse 分析中数据流 activity 源中的 SQL 查询?

我正在构建一个突触分析管道,它在事实中执行增量加载 table。首先,使用查找 activity 查询 table 以获得最新的 LoadDate 值。然后将返回值设置为变量并作为参数传递给数据流 activity.

我正在努力获取正确的数据流 运行。我试图将 SQL 查询与 'SetVariable' activity 中的过滤器值连接起来,但出现 'The store configuration is not defined.' 错误。当我仅将转换后的 LoadDate 值传递给数据流中的源查询时,也会发生同样的情况 activity:

"SELECT top 10 * FROM dbo.facts WHERE timestamp > @pipeline().parameters.LastLoadedDate"

请试试这个SQL:

concat('select top 10 * FROM dbo.facts WHERE timestamp >', $yourParameterName)

在数据流中,不能像这样使用管道表达式@pipeline().parameters.LastLoadedDate,应该在数据流中使用参数值

经过多次尝试和错误尝试,这个语法对我有用:

concat("SELECT * FROM dbo.facts WHERE timestamp > CONVERT(datetime2, '" , $LastLoadedDate, "')")

关键是使用双引号来包裹连接的字符串...