Neo4j
CertifiedTasks that run Cypher queries against Neo4j.
Provide Neo4j URI/auth credentials and Cypher statements with parameters to read or write graph data, returning query results for analytics or lineage workflows.
Neo4j
Tasks that run Cypher queries against Neo4j.
Provide Neo4j URI/auth credentials and Cypher statements with parameters to read or write graph data, returning query results for analytics or lineage workflows.
tasks
How to use the Neo4j plugin
Run Cypher queries and batch-load data into Neo4j from Kestra flows.
Authentication
Set url to your Neo4j endpoint (Bolt URI, e.g. bolt://localhost: 7687, or HTTP(S)). For basic auth, set username and password. For token auth, set bearerToken (Base64-encoded). Store secrets in secrets and apply connection properties globally with plugin defaults.
Tasks
Query runs a Cypher statement set in query. Control result handling with storeType: NONE (default, discards results), FETCH returns all rows, FETCHONE returns the first row, STORE writes results to internal storage.
Batch bulk-loads data from a file in internal storage — set from to a kestra:// URI and query to a Cypher UNWIND $props AS ... statement. Control batch size with chunk (default 1000).
