RunMongoAggregation 2025.10.2.19¶

捆绑包¶

org.apache.nifi | nifi-mongodb-nar

描述¶

每当收到 FlowFile 时运行聚合查询的处理器。

标签¶

aggregate、aggregation、mongo

输入要求¶

ALLOWED

支持敏感的动态属性¶

false

属性¶

属性	描述
批处理大小	同一批次中从服务器返回的元素数量。
Mongo 集合名称	要使用的集合的名称
Mongo 数据库名称	要使用的数据库名称
allow-disk-use	将此设置为 True 可允许将数据写入临时文件，以防止在处理大型数据集时在聚合管道暂存期间超过最大内存使用限制。
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-agg-query	要执行的聚合查询。
mongo-charset	指定文档数据的字符集。
mongo-client-service	如果已配置，则此属性将使用分配的客户端服务进行连接共享。
mongo-date-format	用于格式化从 Mongo 返回的日期字段的日期格式字符串。它仅在 JSON 输出格式设置为标准 JSON 时适用。
mongo-query-attribute	如有设置，则查询将写入输出 FlowFile 中的指定属性。
results-per-flowfile	每次放入 FlowFile 的结果数量整个正文将被视为一个包含多个结果的 JSON 数组。

关系¶

名称	描述
failure	查询失败后，输入 FlowFile 将发送到此关系。
original	查询成功后，输入 FlowFile 将发送到此关系。
results	聚合的结果集将发送到此关系。