NiFi GetMongo 永远获取数据

Question

我在 MongoDB 中有数百万条记录，我想使用 NiFi 来移动数据。这是我要运行的场景：

1) 我将设置 NiFi

2) NiFi 将自动获取每批 100 条记录的记录。

3) 完成后，将在添加新条目时获取。

我尝试将这个场景应用到一个小型 MongoDB 集合（从 mongo 获取并存储为一个文件），我看到 NiFi 一直在重复这个过程并且它正在复制记录。

这是我在 NiFi 上创建的流程：

有解决这个问题的建议吗？

Answer 1

很遗憾，GetMongo 没有状态跟踪功能。我已经解释过类似的问题。你可以找到他们：

• Apache NIFI Jon is not terminating automatically
• Apache Niffi getMongo Processor