从 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 db 集合中定义 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 time stamp，您需要匹配格式。

希望对您有所帮助。