Support Questions

Find answers, ask questions, and share your expertise

Nifi - PutMongo(Record) Processor issue




We are having an issue with PutMongoRecord Processor(same for PutMongo as well) which is routing the flowfiles to the failure relationship when the Mongo database(or the server hosting the db) is down. We have a set-up which looks like below on a high-level overview.



As you can clearly see, all the failure relationships of different processors in the dataflow are connected to an Error Handling Process Group. Now, when the Mongodb is down, the PutMongoRecord processor is routing all the flowfiles to the failure relationship. I know that a processor could route a flowfile to the failure relationship for multitude of reasons and I believe PutMongoRecord routing the flowfiles to failure when the database is down is not ideal for our scenario. Our dataflow is real-time streaming and when mongo database is down and flowfiles get routed to failure relationship, we get hundreds of emails because of the PutEmail processor in the Error Handling Process Group. We configured the Error Handling process group to check if we get any erroneous data which is against our schema or whatever maybe the reason.

Is there any logic you guys help me in this scenario?

I also observed that when we load the data to a RDBMS, lets say SQL Server, using the PutSql processor, it doesn’t route the flowfiles to the failure relationship when the sql server is down. I remember the flowfiles were held up in the connector above it until the db is up and running. I also noticed that PutSql has retry and PutMongo(and Record) doesn’t have any retry.

Please help me what could be best thing for us to as this is critical to us.




Take a Tour of the Community
Don't have an account?
Your experience may be limited. Sign in to explore more.