Batch
type: "io.kestra.plugin.neo4j.Batch"
Execute a batch query to a Neo4j database.
# Examples
id: "batch"
type: "io.kestra.plugin.neo4j.Batch"
url: "{{url}}"
username: "{{username}}"
password: "{{password}}"
query: |
UNWIND $props AS properties
MERGE (y:Year {year: properties.year})
MERGE (y)<-[:IN]-(e:Event {id: properties.id})
RETURN e.id AS x ORDER BY x
from: {{ outputs['previous-task-id'].uri }}
chunk: 1000
# Properties
# bearerToken
- Type: string
- Dynamic: ✔️
- Required: ❌
Token base64 encoded token
# chunk
- Type: integer
- Dynamic: ✔️
- Required: ✔️
- Default:
1000
The size of chunk for every bulk request
# from
- Type: string
- Dynamic: ✔️
- Required: ✔️
Source file URI
# password
- Type: string
- Dynamic: ✔️
- Required: ❌
Password to use in case of basic auth
If not specified, won't use basic auth
# query
- Type: string
- Dynamic: ✔️
- Required: ✔️
Query to execute batch, must use UNWIND
The query must have the row :
"UNWIND $props AS X" with $props the variable where
we input the source data for the batch.
# url
- Type: string
- Dynamic: ❓
- Required: ❌
The URL to a Neo4j instance
The URL can either be in HTTP or Bolt format
# username
- Type: string
- Dynamic: ✔️
- Required: ❌
Username to use in case of basic auth
If not specified, won't use basic
# Outputs
# rowCount
- Type: integer
The count of executed queries
# updatedCount
- Type: integer
The updated rows count