Document toolboxDocument toolbox

Neo4j Sink

Description

This unit is a Sink unit type.

A unit that stores events into a Neo4j database.

All events enter through the in port. Then, the unit executes the query specified in its properties. Successful results are sent to the Neo4j database using the connection details configured for the unit. 

If an error occurs, an event is enriched with standard error fields and sent to the error output port.

Configuration

After dragging this unit into the Flow canvas, double-click it to access its configuration options. The following table describes the configuration options of this unit:

Tab

Field

Description

Tab

Field

Description

General

Name

Enter a name for the unit. It must start with a letter, and cannot contain spaces. Only letters, numbers, and underscores are allowed.

Description

Enter a description detailing the scope of the unit.

Query

Expression, written in Cypher, that will determine the behavior of the unit.

Parameters

Parameters

A list of field names to be used as parameters in the query.

Connection

Neo4j url

The URL (bolt://ip:port) of the host running the Neo4j database.

Username

The client name to access Neo4j.

Password

The password requested to access Neo4j.

Input ports

Port

Description

Port

Description

in

All events enter through this port.

Output ports

Port

Description

Port

Description

error

Outputs all events that produced some error during processing. These events have two additional fields, error, and exception, that describe the error.