RunMongoAggregation Processor
描述
每当收到 FlowFile 时运行聚合查询的处理器。
标签
属性
| 名称 | 默认值 | 可选值 | 描述 |
|---|---|---|---|
| Client Service | | 控制器服务 API：MongoDBClientServicecn.org.acal.lynxus-lynxus-mongodb-client-service-api-nar-2.11.8 | 如果配置，此属性将使用分配的客户端服务进行连接池。 |
| Mongo Database Name | | 要使用的数据库的名称 支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值） | |
| Mongo Collection Name | | 要使用的集合的名称 支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值） | |
| Character Set | UTF-8 | 指定文档数据的字符集。 支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值） | |
| Query | | 要执行的聚合查询。 支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值） | |
| 允许使用磁盘 | false |
| 设置为 true 以启用将数据写入临时文件，以防止在处理大数据集时超出聚合管道阶段的最大内存使用限制。 |
| JSON Type | Extended |
| 默认情况下，MongoDB 的 Java 驱动程序返回 \"扩展 JSON\"。此变体 JSON 的某些特性可能会导致其他仅期望标准 JSON 类型和约定的 JSON 解析器出现问题。此配置设置控制是使用扩展 JSON 还是提供符合标准 JSON 的清晰视图。 |
| Query Output Attribute | | 如果设置，查询将被写入输出 FlowFiles 上的指定属性。 支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值） | |
| Batch Size | 100 | 一批中从服务器返回的元素数量。 | |
| Results Per FlowFile | 1 | 一次将多少个结果放入 FlowFile 中。 整个正文将被视为结果的 JSON 数组。 | |
| Date Format | yyyy-MM-dd'T'HH:mm:ss'Z' | 用于格式化从 Mongo 返回的日期字段的日期格式字符串。仅在 JSON 输出格式设置为标准 JSON 时应用。 支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值） |
关系 (Relationships)
| 名称 | 描述 | 自动终止 |
|---|---|---|
failure | 当查询失败时，输入 FlowFile 将发送到此关系。 | 否 |
original | 当查询成功时，输入 FlowFile 将发送到此关系。 | 否 |
results | 聚合的结果集将被发送到该关系。 | 否 |
状态管理
该组件不存储状态。
受限 (Restricted)
该组件不受限。
输入要求
该组件允许有传入连接。
详细说明
RunMongoAggregation
说明
该 Processor 基于用户自定义设置执行 MongoDB 聚合查询。以下是一个 此类查询的示例（以及预期的输入形式）：
[
{
"$project": {
"domain": 1
},
"$group": {
"_id": {
"domain": "$domain"
},
"total": {
"$sum": 1
}
}
}
]