RunMongoAggregation
描述:
每当收到流文件时运行聚合查询
标签:
mongo, aggregation, aggregate, 聚合
参数:
如下列表中,必填参数则标识为加粗. 其他未加粗参数,则表示为可选参数。表中同时提到参数默认值设置, 并且 参数还支持 表达式语言.
名字 | 默认值 | 允许值列表 | 描述 |
---|---|---|---|
连接 URI | MongoURI, 基本格式为: mongodb://host1[:port1],host2[:port2],...] 支持表达式语言 (仅支持变量) | ||
数据库名 | 用于连接的数据库名字 支持表达式语言 (支持流属性和变量) | ||
连接名 | 用于连接的名字 支持表达式语言 (支持流属性和变量) | ||
SSL服务 | 控制器服务API: SSLContextService 实现: StandardRestrictedSSLContextService StandardSSLContextService | 用于提供客户端TLS/SSL安全认证连接信息的服务 | |
客户端认证 | 必须 | - 请求 - 必须 - 不需要 | 连接到安全(TLS/SSL)群集时的客户端身份验证策略。可能的值是REQUIRED, WANT, NONE。此属性仅在定义和启用了SSL服务时有效 |
字符编码 | UTF-8 | 指定文档数据的字符集编码 支持表达式语言 (支持流属性和变量) | |
语句 | 用于执行聚合的语句 支持表达式语言 (支持流属性和变量) | ||
Allow Disk Use | false | - true - false | Set this to true to enable writing data to temporary files to prevent exceeding the maximum memory use limit during aggregation pipeline staged when handling large datasets. |
JSON类型 | 扩展 JSON | - 扩展 JSON - 标准 JSON | 默认情况下,MongoDB的Java驱动将返回"扩展 JSON"格式。但是会导致其他一些JSON解析出现问题,所以可支持标准JSON。该参数决定是否支持扩展JSON还是标准JSON输出。 |
语句输出属性 | 如果设置,语句将被记录到该特殊属性并同数据流一并输出。 支持表达式语言 (支持流属性和变量) | ||
分批数量 | 100 | 每次从服务器返回的元素大小 | |
结果数 | 1 | 决定每次输出数据流中需要放入多少个结果。整个将作为JSON数组。 | |
日期格式 | yyyy-MM-dd'T'HH:mm:ss'Z' | Specifies format for date. 支持表达式语言 (支持流属性和变量) | |
SSL服务 | 控制器服务API: SSLContextService 实现: StandardRestrictedSSLContextService StandardSSLContextService | 用于提供客户端TLS/SSL安全认证连接信息的服务 | |
客户端认证 | 必须 | - 请求 - 必须 - 不需要 | 连接到安全(TLS/SSL)群集时的客户端身份验证策略。可能的值是REQUIRED, WANT, NONE。此属性仅在定义和启用了SSL服务时有效 |
连线:
名字 | 描述 |
---|---|
empty | 没有结果将输出到此连线 |
results | 聚合的结果集将输出到此连线 |
failure | 读取失败后的数据流将输出到此失败连线 |
original | 成功读取后的原始数据流将输出到此原始连线 |
读取属性:
未提供。
写入属性:
未提供。
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件允许提供输入流。
系统资源考量:
未提供。