sql - 从cosmos db中查询特定时间范围的数据并通过azure数据工厂存储在sql数据库中

Question

我正在使用 Azure 数据工厂 V2，并希望使用 SQL 查询将存储为文档的 json 数据从 Azure cosmos db 复制到 azure sql 表。

情况:我想从 Cosmos db 查询最近一小时的 json 文件并将其存储在 sql 表中。为此，我在数据工厂中创建一个新的触发器，每 1 小时重复一次 SQL 查询。

问题:首先，我编写了一个查询，从 cosmos db 中读取所有数据，并且工作正常，但我只想查询 cosmos db 中最后一小时内存储的数据。

我需要什么？在 Sql 中，如何编写查询来获取最近一小时内存储在 cosmos db 中的新文件？

Answer 1

您可以在 Cosmos 数据库集合中定义一个 udf。

function getLastHourTime(){
    var date = new Date();
    var a = date.setHours(-1);
    return a;
}

修改你的sql为:

SELECT * FROM c where c.time >= udf.getLastHourTime()

注意:udf.getLastHourTime() 返回 Unix 时间戳 ，需要匹配格式。

希望对您有帮助。