This uses FlowFile records as input to perform graph mutations. Each record is associated with an individual query/mutation, and a FlowFile will be output for each successful operation. Failed records will be sent as a single FlowFile to the failure relationship.
graph, gremlin, cypher
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 Name | API Name | Default Value | Allowable Values | Description |
|---|---|---|---|---|
| Client Service | client-service | Controller Service API: GraphClientService Implementations: OpenCypherClientService Neo4JCypherClientService GremlinClientService | The graph client service for connecting to a graph database. | |
| Record Reader | reader-service | Controller Service API: RecordReaderFactory Implementations: Syslog5424Reader CEFReader ReaderLookup CiscoEmblemSyslogMessageReader CSVReader GrokReader SyslogReader JsonTreeReader JsonPathReader XMLReader AvroReader JASN1Reader ExcelReader ParquetReader EBCDICRecordReader WindowsEventLogReader IPFIXReader ScriptedReader | The record reader to use with this processor. | |
| Failed Record Writer | writer-service | Controller Service API: RecordSetWriterFactory Implementations: JsonRecordSetWriter ParquetRecordSetWriter CSVRecordSetWriter ScriptedRecordSetWriter XMLRecordSetWriter FreeFormTextRecordSetWriter AvroRecordSetWriter RecordSetWriterLookup | The record writer to use for writing failed records. | |
| Graph Record Script | record-script | Script to perform the business logic on graph, using flow file attributes and custom properties as variable-value pairs in its logic. Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
Supports Sensitive Dynamic Properties: No
Dynamic Properties allow the user to specify both the name and value of a property.
| Name | Value | Description |
|---|---|---|
| A dynamic property to be used as a parameter in the graph script | The variable name to be set | Uses a record path to set a variable as a parameter in the graph script Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| Name | Description |
|---|---|
| response | The response object from the graph server. |
| failure | Flow files that fail to interact with graph server. |
| original | Original flow files that successfully interacted with graph server. |
| Name | Description |
|---|---|
| graph.operations.took | The amount of time it took to execute all of the graph operations. |
| record.count | The number of records unsuccessfully processed (written on FlowFiles routed to the 'failure' relationship. |