1. Have you validated your query? I've been using GetMongo lately for a fairly large bulk ingestion job, and so far it's worked fine.
2. You can try something like this pattern: https://stackoverflow.com/questions/44573618/how-to-get-iso-string-in-nifi-getmongo-query-field/44725438#44725438 * Add a timestamp field to each object. * Use a $where with a stored procedure that calculates the last 5 minutes. * Set NiFi to run that GetMongo every 5 minutes. Mike On Thu, Jun 29, 2017 at 12:39 PM, Kavitha Alahari <[email protected] > wrote: > Hello Team, > > I am trying to pull the data from MongoDB and try to put in other Mongo > DB. For this I used GetMongo and PutMongo processors. Unfortunately none of > the query is working in getMongo. However it is working when no query is > there. Could you please provide me a sample query to use in Get Mongo. > > Also I have another requirement. Whenever data comes to a collection in > MongoDB, the same data has to move into another collection of a different > DB in the same server. Can we achieve this using Nifi. > > Your help is really appreciated. > > Regards > Kavitha Alahari >
