GetMongo 2025.10.2.19¶

捆绑包¶

org.apache.nifi | nifi-mongodb-nar

描述¶

从用户指定的查询加载的 FlowFiles 中的文档创建 MongoDB。

标签¶

get、mongodb、read

输入要求¶

ALLOWED

支持敏感的动态属性¶

false

属性¶

属性	描述
批处理大小	同一批次中要从服务器返回的元素数量
Limit	要返回的最大元素数
Mongo 集合名称	要使用的集合的名称
Mongo 数据库名称	要使用的数据库名称
投影	要从结果集中的文档返回的字段；必须是有效的 BSON 文档
查询	用于查找的选择标准。如果该字段为空，它将从另一个处理器的传入连接中查找输入，从而在 FlowFile 的正文中提供查询作为一个有效的 JSON 文档。如果此字段为空并且启用了计时器而不是传入连接，则会使用“{}”查询提取全部集合。
排序	用于排序的字段；必须是有效的 BSON 文档
get-mongo-send-empty	如果查询成功执行但未返回任何结果，则发送一个表示没有结果的空 JSON 文档。
json-type	By default, MongoDB's Java driver returns "extended JSON". Some of the features of this variant of JSON may cause problems for other JSON parsers that expect only standard JSON types and conventions. This configuration setting controls whether to use extended JSON or provide a clean view that conforms to standard JSON.
mongo-charset	指定文档数据的字符集。
mongo-client-service	如果已配置，则此属性将使用分配的客户端服务进行连接共享。
mongo-date-format	用于格式化从 Mongo 返回的日期字段的日期格式字符串。它仅在 JSON 输出格式设置为标准 JSON 时适用。
mongo-query-attribute	如有设置，则查询将写入输出 FlowFile 中的指定属性。
results-per-flowfile	每个 FlowFile 中包含多少结果。整个正文将被视为一个包含多个结果的 JSON 数组。
use-pretty-printing	选择是否将查询结果中的 JSON 漂亮地打印下来。选择“True”会大幅增加磁盘空间使用，具体取决于 JSON 文档的复杂度

关系¶

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

写入属性¶

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