我希望在 ADF 中实现增量表加载管道。我想要执行查询以从 Azure SQL 数据库中的表获取最新时间戳。然后,将该值存储为 ADF 中的变量,以便我可以在复制数据事件的“源”查询中引用它。
目标是仅从时间戳大于 SQL 表中最新时间戳的 API 请求数据。
此功能可以在 ADF 管道中实现吗?或者我是否需要查看 Azure 函数或数据流?
最佳答案
使用数据工厂这绝对是可能的。您可以使用查找事件或存储过程,但团队刚刚发布了新的脚本事件:
这将返回如下结果:
{
"resultSetCount": 1,
"recordsAffected": 0,
"resultSets": [
{
"rowCount": 1,
"rows": [
{
"MaxDate": "2018-03-20"
}
]
...
}
以下是将其读入变量的表达式:
@activity('Script1').output.resultSets[0].rows[0].MaxDate
关于Azure 数据工厂管道 - 将单值源查询输出存储为变量,然后在复制数据事件中使用,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/71929985/