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.