Processor to write the JSON content of a FlowFile to RethinkDB (https://www.rethinkdb.com/). The flow file should contain either JSON Object an array of JSON documents


rethinkdb, stream, insert, update, write, put


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, whether a property supports the NiFi Expression Language, and whether a property is considered "sensitive", meaning that its value will be encrypted. Before entering a value in a sensitive property, ensure that the nifi.properties file has an entry for the property nifi.sensitive.props.key.

NameDefault ValueAllowable ValuesDescription
DB NameRethinkDB database to connect to
HostnamelocalhostRethinkDB hostname
DB Port28015RethinkDB database port to connect to
UsernameUsername for accessing RethinkDB
PasswordPassword for user
Sensitive Property: true
Table nameRethinkDB table to connect to
Character SetUTF-8Specifies the character set of the document data.
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry)
Conflict strategyupdate
  • Update Update the document having same id with new values
  • Replace Replace the document with having same id new document
  • Error Return error if the document with same id exists
Conflict strategy to be used in case of inserting existing document.
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry)
Durablity of documentshard
  • Hard Save change to disk before ack
  • Soft Don't save changes to disk before ack
Durability of documents being inserted
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry)
Max size of documents1 MBMaximum size of documents allowed to be posted in one batch


successSucessful FlowFiles are routed to this relationship
failureFailed FlowFiles are routed to this relationship

Reads Attributes:

None specified.

Writes Attributes:

rethinkdb.error.messageRethinkDB error message
rethinkdb.insert.errorsError count while inserting documents
rethinkdb.insert.deletedNumber of documents deleted
rethinkdb.insert.generated_keysKeys generated on inserting documents
rethinkdb.insert.insertedNumber of documents inserted
rethinkdb.insert.replacedNumber of documents replaced
rethinkdb.insert.skippedNumber of documents skipped because they already existed
rethinkdb.insert.unchangedNumber of documents unchanged since they already existed
rethinkdb.insert.first_errorFirst error while inserting documents
rethinkdb.insert.warningsWarning message in case of large number of ids being returned on insertion

State management:

This component does not store state.


This component is not restricted.

Input requirement:

This component requires an incoming relationship.

System Resource Considerations:

None specified.

See Also:

GetRethinkDB, DeleteRethinkDB