Description:

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

Tags:

rethinkdb, stream, insert, update, write, 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, 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.

Name	Default Value	Allowable Values	Description
DB Name			RethinkDB database to connect to
Hostname	localhost		RethinkDB hostname
DB Port	28015		RethinkDB database port to connect to
Username			Username for accessing RethinkDB
Password			Password for user Sensitive Property: true
Table name			RethinkDB table to connect to
Character Set	UTF-8		Specifies the character set of the document data. Supports Expression Language: true
Conflict strategy	update	* Update * Replace * Error	Conflict strategy to be used in case of inserting existing document. Supports Expression Language: true
Durability of documents	hard	* Hard * Soft	Durability of documents being inserted Supports Expression Language: true
Max size of documents	1 MB		Maximum size of documents allowed to be posted in one batch

Relationships:

Name	Description
success	Successful FlowFiles are routed to this relationship
failure	Failed FlowFiles are routed to this relationship

Reads Attributes:

None specified.

Writes Attributes:

Name	Description
rethinkdb.error.message	RethinkDB error message
rethinkdb.insert.errors	Error count while inserting documents
rethinkdb.insert.deleted	Number of documents deleted
rethinkdb.insert.generated_keys	Keys generated on inserting documents
rethinkdb.insert.inserted	Number of documents inserted
rethinkdb.insert.replaced	Number of documents replaced
rethinkdb.insert.skipped	Number of documents skipped because they already existed
rethinkdb.insert.unchanged	Number of documents unchanged since they already existed
rethinkdb.insert.first_error	First error while inserting documents
rethinkdb.insert.warnings	Warning message in case of large number of ids being returned on insertion

State management:

This component does not store state.

Restricted:

This component is not restricted.

Input requirement:

This component requires an incoming relationship.

See Also:

GetRethinkDB, DeleteRethinkDB