Запросите данные определенного временного диапазона из базы данных cosmos и сохраните их в базе данных sql через фабрику данных Azure

Question

Я использую фабрику данных Azure V2 и хочу скопировать данные json, хранящиеся в виде документов из базы данных Azure cosmos db, в таблицу SQL Azure, используя SQL-запрос.

Ситуация: Iхочу запросить только последние json-файлы Cosmos db и сохранить их в таблице sql.Чтобы сделать это, я создаю новый триггер в моей фабрике данных, который повторяет запрос sql каждые 1 час.

Проблема: Сначала я написал запрос, который считывает все данные из базы данных космоса иэто работает нормально, но я хочу запросить только данные, которые хранятся в течение последнего часа в космосе дБ.

Что мне нужно? В Sql, как написать запрос, чтобы получить тольконовые файлы, которые хранятся в течение последнего часа в космосе дБ?

Answer 1

Вы можете определить udf в вашей коллекции cosmos db.

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, вынужно соответствовать формату.

Надеюсь, это поможет вам.