GetMongoRecord 2025.5.31.15¶

捆绑包¶

org.apache.nifi | nifi-mongodb-nar

描述¶

GetMongo 的基于记录的版本，使用记录写入器来写入 MongoDB 结果集。

标签¶

fetch、get、json、mongo、mongodb、record

输入要求¶

ALLOWED

支持敏感的动态属性¶

false

属性¶

属性	描述
批处理大小	同一批次中要从服务器返回的元素数量
Limit	要返回的最大元素数
Mongo 集合名称	要使用的集合的名称
Mongo 数据库名称	要使用的数据库名称
投影	要从结果集中的文档返回的字段；必须是有效的 BSON 文档
查询	用于查找的选择标准。如果该字段为空，它将从另一个处理器的传入连接中查找输入，从而在 FlowFile 的正文中提供查询作为一个有效的 JSON 文档。如果此字段为空并且启用了计时器而不是传入连接，则会使用“{}”查询提取全部集合。
排序	用于排序的字段；必须是有效的 BSON 文档
get-mongo-record-writer-factory	用于写入结果集的记录写入器。
mongo-client-service	如果已配置，则此属性将使用分配的客户端服务进行连接共享。
mongo-query-attribute	如有设置，则查询将写入输出 FlowFile 中的指定属性。
mongodb-schema-name	配置的架构注册表中用于查询结果的架构的名称。

关系¶

名称	描述
failure	在查询执行中失败的所有输入 FlowFiles 都将发送到此处。
original	在查询执行中成功的所有输入 FlowFiles 都将发送到此处。
success	所有包含成功查询执行结果的 FlowFiles 都将发送到处。

写入属性¶

名称	描述
mongo.database.name	结果来自的数据库。
mongo.collection.name	结果来自的集合。