QueryIoTDBRecord

Description:

Query Apache IoTDB and write results as Records

Tags:

IoT, Timeseries

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
HostHostIoTDB server host address
PortPort6667IoTDB server port number
UsernameUsernameUsername for access to IoTDB
PasswordPasswordPassword for access to IoTDB
Sensitive Property: true
QueryQueryIoTDB query to be executed
Supports Expression Language: true (will be evaluated using flow file attributes and Environment variables)
Fetch SizeFetch Size10000Maximum number of results to return in a single chunk. Configuring 1 or more enables result set chunking
Supports Expression Language: true (will be evaluated using flow file attributes and Environment variables)
Record WriterRecord WriterController Service API:
RecordSetWriterFactory
Implementations: XMLRecordSetWriter
FreeFormTextRecordSetWriter
AvroRecordSetWriter
ScriptedRecordSetWriter
JsonRecordSetWriter
ParquetRecordSetWriter
RecordSetWriterLookup
CSVRecordSetWriter
Service for writing IoTDB query results as records

Relationships:

NameDescription
successProcessing succeeded
failureProcessing failed

Reads Attributes:

None specified.

Writes Attributes:

NameDescription
iotdb.error.messageError message written on query failures
mime.typeContent Type based on configured Record Set Writer

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.