Member since
02-05-2019
2
Posts
0
Kudos Received
0
Solutions
02-14-2019
04:41 PM
I am trying to get all documents within a time range using RunMongoAggreation. In console I tried with below query and it worked fine. db.collection.find(
{ "header.timestamp": {
$gte: ISODate("2018-12-20T05:19:35.904Z"),
$lt: ISODate("2018-12-20T05:21:44.509Z")
} }
)
Flowfile has below properties startTimestamp: 2018-12-20T05:19:35.904Z endTimestamp: 2018-12-20T05:21:44.509Z Below is the query being used in RunMongoAggreation {
"header.timestamp": {
"$gt": {
"$date": "${startTimestamp}"
},
"$lt": {
"$date": "${endTimestamp}"
}
}
}
Its not working gettting below exception com.fasterxml.jackson.databind.exc.mismatchedinputexception cannot deserialize instance of `java.util.arraylist` out of START_OBJECT token
... View more
Labels:
- Labels:
-
Apache NiFi
02-05-2019
10:15 PM
I am trying to insert a document into mongodb using apache NiFi. I want to insert a document just from Flow File attributes but not the Flow File content. I have tried using PutMongo processor but it insert the content of the Flow file which I don't want it to insert. I need to insert a custom document by using the flow file's attributes.
... View more
Labels:
- Labels:
-
Apache NiFi