A processor that runs an aggregation query whenever a flowfile is received.
| Display Name | API Name | Default Value | Allowable Values | Description |
|---|
| Client Service | mongo-client-service | | Controller Service API:
MongoDBClientService
Implementation: MongoDBControllerService | If configured, this property will use the assigned client service for connection pooling. |
| Mongo URI | Mongo URI | | | MongoURI, typically of the form: mongodb://host1[:port1][,host2[:port2],...]
Supports Expression Language: true (will be evaluated using variable registry only) |
| Mongo Database Name | Mongo Database Name | | | The name of the database to use
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| Mongo Collection Name | Mongo Collection Name | | | The name of the collection to use
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| SSL Context Service | ssl-context-service | | Controller Service API:
SSLContextService
Implementations: StandardRestrictedSSLContextService
StandardSSLContextService | The SSL Context Service used to provide client certificate information for TLS/SSL connections. |
| Client Auth | ssl-client-auth | REQUIRED | | Client authentication policy when connecting to secure (TLS/SSL) cluster. Possible values are REQUIRED, WANT, NONE. This property is only used when an SSL Context has been defined and enabled. |
| Character Set | mongo-charset | UTF-8 | | Specifies the character set of the document data.
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| Query | mongo-agg-query | | | The aggregation query to be executed.
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| Allow Disk Use | allow-disk-use | 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 Type | json-type | Extended JSON | - Extended JSON
 - Standard JSON
| 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. |
| Query Output Attribute | mongo-query-attribute | | | If set, the query will be written to a specified attribute on the output flowfiles.
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| Batch Size | Batch Size | 100 | | The number of elements returned from the server in one batch. |
| Results Per FlowFile | results-per-flowfile | 1 | | How many results to put into a flowfile at once. The whole body will be treated as a JSON array of results. |
| Date Format | mongo-date-format | yyyy-MM-dd'T'HH:mm:ss'Z' | | The date format string to use for formatting Date fields that are returned from Mongo. It is only applied when the JSON output format is set to Standard JSON. Full documentation for format characters can be found here: https://docs.oracle.com/javase/8/docs/api/java/text/SimpleDateFormat.html
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| SSL Context Service | ssl-context-service | | Controller Service API:
SSLContextService
Implementations: StandardRestrictedSSLContextService
StandardSSLContextService | The SSL Context Service used to provide client certificate information for TLS/SSL connections. |
| Client Auth | ssl-client-auth | REQUIRED | | Client authentication policy when connecting to secure (TLS/SSL) cluster. Possible values are REQUIRED, WANT, NONE. This property is only used when an SSL Context has been defined and enabled. |