RunMongoAggregation 2025.5.31.15¶

捆绑包¶

org.apache.nifi | nifi-mongodb-nar

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

aggregate、aggregation、mongo

ALLOWED

false

属性	描述
批处理大小	同一批次中从服务器返回的元素数量。
Mongo 集合名称	要使用的集合的名称
Mongo 数据库名称	要使用的数据库名称
allow-disk-use	将此设置为 True 可允许将数据写入临时文件，以防止在处理大型数据集时在聚合管道暂存期间超过最大内存使用限制。
json-type	默认情况下，MongoDB 的 Java 驱动程序返回“扩展 JSON”。该 JSON 变体的某些特性可能会给其他只期望标准 JSON 类型和约定的 JSON 解析器带来问题。此配置设置控制是使用扩展 JSON 的视图还是提供符合标准 JSON 的简洁视图。
mongo-agg-query	要执行的聚合查询。
mongo-charset	指定文档数据的字符集。
mongo-client-service	如果已配置，则此属性将使用分配的客户端服务进行连接共享。
mongo-date-format	用于格式化从 Mongo 返回的日期字段的日期格式字符串。它仅在 JSON 输出格式设置为标准 JSON 时适用。
mongo-query-attribute	如有设置，则查询将写入输出 FlowFile 中的指定属性。
results-per-flowfile	每次放入 FlowFile 的结果数量整个正文将被视为一个包含多个结果的 JSON 数组。