Neo4j Query

Neo4j Query
Certified
Execute a Neo4j Cypher query

Runs a rendered Cypher statement on a Neo4j database and handles results as fetch, fetch-one, store to internal storage, or no-op (default NONE).

yaml
type: io.kestra.plugin.neo4j.Query

Examples

yaml
id: neo4j_query
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.neo4j.Query
    url: "{{ url }}"
    username: "{{ username }}"
    password: "{{ password }}"
    query: |
        MATCH (p:Person)
        RETURN p
    storeType: FETCH

Properties

bearerToken string

Bearer token

Base64-encoded bearer token used when basic credentials are not provided.

password string

Password for basic auth

Used with username; ignored if credentials are absent.

pluginDefaultsRef string

Reference (ref) of the pluginDefaults to apply to this task.

query string

Cypher query to run

Rendered with Flow variables before execution; must be valid for the chosen result mode.

storeType string

DefaultNONE

Possible Values

STOREFETCHFETCHONENONE

Result handling mode

FETCHONE returns the first row; FETCH returns all rows; STORE writes all rows to internal storage; NONE skips result handling (default).

url string

Neo4j endpoint URL

Bolt or HTTP(S) URI used to open the driver connection.

username string

Username for basic auth

Used with password; takes precedence over bearer tokens when both are set.

Outputs

row object

First fetched row

Populated when storeType is FETCHONE.

rows array

SubTypeobject

Fetched rows

Populated when storeType is FETCH.

size integer

Row count

Number of rows fetched or stored.

uri string

Formaturi

Stored result URI

Populated when storeType is STORE; points to internal storage.

Metrics

fetch.size counter

The number of records fetched in FETCH or FETCHONE mode.

store.size counter

The number of records stored in STORE mode.

Dataform

Tasks that run Dataform data transformations through the Dataform CLI.

Data

Pinecone

Interact with Pinecone, a managed vector database, from your Kestra workflows. Create serverless indexes, upsert vectors, query by similarity, fetch or delete vectors by ID, and inspect index statistics.

AIData

Neo4j QueryCertifiedExecute a Neo4j Cypher query

More Plugins in this Category

Dataform

Pinecone

Neo4j Query
Certified
Execute a Neo4j Cypher query