Я пытаюсь запустить процессор GetMongo в Apache NiFi.Я могу заставить базовый запрос работать нормально и выводить записи на мой жесткий диск (только для первоначального тестирования. В конечном итоге пойдет к клиенту Hadoop)
Моя проблема в том, что я хочу запускать запрос каждые 10 минути вернуть ТОЛЬКО новые записи за последние 10 минут.Запрос, который я протестировал на своем локальном клиенте Mongo:
{"createdAt": {$gte: new Date(ISODate().getTime() - 1000 * 60 * 5)}}
Сначала я подумал, что ему не нравится динамическая часть, поэтому я попытался вставить статическую метку времени.Но NiFi сказал мне, что каждый запрос, который я пробовал, недействителен.
Есть несколько достойных руководств, но они очень специфичны для SQL-процессоров в NiFi и интересуются, есть ли у кого-нибудь опыт создания потока на основе динамических запросов с Mongoв нифи.Большое спасибо заранее.