NiFi RunMongoAggreation - Как получить все документы за определенный промежуток времени? - PullRequest
Новая
       6

NiFi RunMongoAggreation - Как получить все документы за определенный промежуток времени?

0 голосов
/ 14 февраля 2019

Я пытаюсь получить все документы за определенный промежуток времени, используя RunMongoAggreation.В консоли я попытался выполнить запрос ниже, и он работал нормально. 

db.collection.find(
{ "header.timestamp": {
        $gte: ISODate("2018-12-20T05:19:35.904Z"),
        $lt: ISODate("2018-12-20T05:21:44.509Z")
    } }
)

Flowfile имеет свойства ниже 

startTimestamp: 2018-12-20T05:19:35.904Z
endTimestamp: 2018-12-20T05:21:44.509Z

Ниже приведен запрос, используемый в RunMongoAggreation 

{
  "header.timestamp": {
    "$gt": {
      "$date": "${startTimestamp}"
    },
    "$lt": {
      "$date": "${endTimestamp}"
    }
  }
}

Это не работает, получая ниже исключения 

com.fasterxml.jackson.databind.exc.mismatchedinputexception cannot deserialize instance of `java.util.arraylist` out of START_OBJECT token
...