GetRethinkDB

Description:

Processor to get a JSON document from RethinkDB (https://www.rethinkdb.com/) using the document id. The FlowFile will contain the retrieved document

Tags:

rethinkdb, get, read, fetch

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.

Display NameAPI NameDefault ValueAllowable ValuesDescription
DB Namerethinkdb-dbnameRethinkDB database to connect to
Hostnamerethinkdb-hostlocalhostRethinkDB hostname
DB Portrethinkdb-port28015RethinkDB database port to connect to
Usernamerethinkdb-usernameUsername for accessing RethinkDB
Passwordrethinkdb-passwordPassword for user
Sensitive Property: true
Table namerethinkdb-tableRethinkDB table to connect to
Character Setrethinkdb-charsetUTF-8Specifies the character set of the document data.
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry)
Document Identifierrethinkdb-document-identifierA FlowFile attribute, or attribute expression used for determining RethinkDB key for the Flow File content
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry)
Read Moderethinkdb-read-modeSingle
  • Single Read values from memory from primary replica (Default)
  • Majority Read values committed to disk on majority of replicas
  • Outdated Read values from memory from an arbitrary replica
Read mode used for consistency
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry)
Max size of documentsrethinkdb-max-document-size1 MBMaximum size of documents allowed to be posted in one batch

Relationships:

NameDescription
successSucessful FlowFiles are routed to this relationship
not_foundDocument not found are routed to this relationship
failureFailed FlowFiles are routed to this relationship

Reads Attributes:

None specified.

Writes Attributes:

NameDescription
rethinkdb.error.messageRethinkDB error message

State management:

This component does not store state.

Restricted:

This component is not restricted.

Input requirement:

This component requires an incoming relationship.

System Resource Considerations:

None specified.

See Also:

PutRethinkDB, DeleteRethinkDB