apache-nifi - 在 Nifi 中，我们如何在 putMongo 之前删除Mongo（来自 ConvertRecord 的流文件）

Question

我已经浏览了几篇文章，但无法在 putMongo 之前删除所有记录。我的流程是：

(1)“调用Http”

(2)“ConvertRecord”（将csv转换为Json）

（3）“ReplaceText”：- 替换值：{}（删除所有记录）替换策略：始终替换评估模式：整个文本

(4)“删除Mongo”

(5) “putMongo”

但我的问题是：如何使“ConvertRecord”的流文件内容可用于 putMongo

标签： apache-nifi

Answer 1

找到了一种在重新加载之前删除所有集合的方法。流程如下： InvokeHttp -> convertRecord -> putFile（将 Json 数据保存在文件中） -> replaceText -> deleteMongo -> fetchFile -> PutMongoRecord