Description:

Bulk ingest documents into MongoDB using a configured record reader.

Tags:

MongoDB, insert, record, put

Properties:

In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.

Name

Default Value

Allowable Values

Description

Mongo URI

MongoURI, typically of the form: MongoDB://host1[:port1][,host2[:port2],...]

Supports Expression Language: true



Mongo Database Name

The name of the database to use

Supports Expression Language: true



Mongo Collection Name

The name of the collection to use

Supports Expression Language: true



SSL Context Service

Controller Service API:


SSLContextService

Implementations:


StandardSSLContextService
StandardRestrictedSSLContextService
The SSL Context Service used to provide client certificate information for TLS/SSL connections.
Client Auth REQUIRED * WANT
* REQUIRED
* NONE
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.

Write Concern

ACKNOWLEDGED * ACKNOWLEDGED
* UNACKNOWLEDGED
* FSYNCED
* JOURNALED
* REPLICA_ACKNOWLEDGED
* MAJORITY
The write concern to use

Record Reader

Controller Service API:


RecordReaderFactory

Implementations:


CSVReader
GrokReader
AvroReader
JsonTreeReader
JsonPathReader
ScriptedReader
Specifies the Controller Service to use for parsing incoming data and determining the data's schema

Insert Batch Size

100 The number of records to group together for one single insert operation against MongoDB.

Relationships:

Name

Description

success All FlowFiles that are written to MongoDB are routed to this relationship
failure All FlowFiles that cannot be written to MongoDB are routed to this relationship

Reads Attributes:

None specified.

Writes Attributes:

None specified.

State management:

This component does not store state.

Restricted:

This component is not restricted.

Input requirement:

This component requires an incoming relationship.