Neo4j sink connector
Write data to Neo4j.
neo4j-java-driver
version 4.4.9
name | type | required | default value |
---|---|---|---|
uri | String | Yes | - |
username | String | No | - |
password | String | No | - |
bearer_token | String | No | - |
kerberos_ticket | String | No | - |
database | String | Yes | - |
query | String | Yes | - |
queryParamPosition | Object | Yes | - |
max_transaction_retry_time | Long | No | 30 |
max_connection_timeout | Long | No | 30 |
common-options | config | no | - |
The URI of the Neo4j database. Refer to a case: neo4j://localhost:7687
username of the Neo4j
password of the Neo4j. required if username
is provided
base64 encoded bearer token of the Neo4j. for Auth.
base64 encoded kerberos ticket of the Neo4j. for Auth.
database name.
Query statement. contain parameter placeholders that are substituted with the corresponding values at runtime
position mapping information for query parameters.
key name is parameter placeholder name.
associated value is position of field in input data row.
maximum transaction retry time(seconds). transaction fail if exceeded
The maximum amount of time to wait for a TCP connection to be established (seconds)
Sink plugin common parameters, please refer to Sink Common Options for details
sink {
Neo4j {
uri = "neo4j://localhost:7687"
username = "neo4j"
password = "1234"
database = "neo4j"
max_transaction_retry_time = 10
max_connection_timeout = 10
query = "CREATE (a:Person {name: $name, age: $age})"
queryParamPosition = {
name = 0
age = 1
}
}
}
- Add Neo4j Sink Connector