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.
| 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 (will be evaluated using flow file attributes and variable registry) | |
| Conflict strategy | update |
| 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 documents | hard |
| Durability of documents being inserted Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| Max size of documents | 1 MB | Maximum size of documents allowed to be posted in one batch |
| Name | Description |
|---|---|
| success | Sucessful FlowFiles are routed to this relationship |
| failure | Failed FlowFiles are routed to this relationship |
| 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 |
