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.