PutMongo 2.3.0¶
BUNDLE¶
org.apache.nifi | nifi-mongodb-nar
DESCRIPTION¶
Writes the contents of a FlowFile to MongoDB
INPUT REQUIREMENT¶
REQUIRED
Supports Sensitive Dynamic Properties¶
false
PROPERTIES¶
Property |
Description |
---|---|
Character Set |
The Character Set in which the data is encoded |
Mode |
Indicates whether the processor should insert or update content |
Mongo Collection Name |
The name of the collection to use |
Mongo Database Name |
The name of the database to use |
Update Method |
MongoDB method for running collection update operations, such as updateOne or updateMany |
Update Query Key |
One or more comma-separated document key names used to build the update query criteria, such as _id |
Upsert |
When true, inserts a document if no document matches the update query criteria; this property is valid only when using update mode, otherwise it is ignored |
mongo-client-service |
If configured, this property will use the assigned client service for connection pooling. |
put-mongo-update-mode |
Choose an update mode. You can either supply a JSON document to use as a direct replacement or specify a document that contains update operators like $set, $unset, and $inc. When Operators mode is enabled, the flowfile content is expected to be the operator part for example: {$set:{“key”: “value”},$inc:{“count”:1234}} and the update query will come from the configured Update Query property. |
putmongo-update-query |
Specify a full MongoDB query to be used for the lookup query to do an update/upsert. NOTE: this field is ignored if the ‘Update Query Key’ value is not empty. |
RELATIONSHIPS¶
NAME |
DESCRIPTION |
---|---|
failure |
All FlowFiles that cannot be written to MongoDB are routed to this relationship |
success |
All FlowFiles that are written to MongoDB are routed to this relationship |
WRITES ATTRIBUTES¶
NAME |
DESCRIPTION |
---|---|
mongo.put.update.match.count |
The match count from result if update/upsert is performed, otherwise not set. |
mongo.put.update.modify.count |
The modify count from result if update/upsert is performed, otherwise not set. |
mongo.put.upsert.id |
The ‘_id’ hex value if upsert is performed, otherwise not set. |