mongodb - Apache Nifi：首先删除条目，然后在 MongoDB 中插入

Question

我想在插入传入文档之前清空集合。集合应始终反映与进入处理器的文档完全相同的文档。

我尝试了 PutMongo Mode: update，它不会删除不属于传入文档的条目。

我尝试将 DeleteMongo 和 PutMong 与Mode: insert. 但同样在这里，DeleteMongo 只删除与传入文档匹配的条目。

我可能必须使用这种方法：https ://stackoverflow.com/a/50874847/1071828并用于GenerateFlowFile({}) -> DeleteMongo删除他收藏的所有条目。这必须在 PutMongo 之前发生。如何链接这些处理器并将原始传入文档发送到 PutMongo？

提前致谢！

标签： mongodbapache-nifi

Answer 1

在这种情况下尝试使用等待和通知处理器。

1. Wait(before PutMongoDB processor)- Until delete happens in MongoDB then insert into MongoDB

2. Notify(after DeleteMongoDB processor)- Once deletes is completed in MongoDB collection then Notify the Wait processor to release the flowfile.