Hi Kavitha,

The query must be a JSON document, you have few examples in the test class
GetMongoTest [1].
Regarding your second question, there is no incremental fetch feature for
the Mongo processors at the moment.

[1]
https://github.com/apache/nifi/blob/master/nifi-nar-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/test/java/org/apache/nifi/processors/mongodb/GetMongoTest.java

Pierre

2017-06-29 18:39 GMT+02:00 Kavitha Alahari <kavitha.alah...@telus.com>:

> 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
>

Reply via email to