Batch
yaml
type: "io.kestra.plugin.neo4j.Batch"
Execute a batch query to a Neo4j database.
Examples
yaml
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
chunk
- Type: integer
- Dynamic: ✔️
- Required: ✔️
- Default:
1000
The size of chunk for every bulk request
from
- Type: string
- Dynamic: ✔️
- Required: ✔️
Source file URI
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.
bearerToken
- Type: string
- Dynamic: ✔️
- Required: ❌
Token base64 encoded token
password
- Type: string
- Dynamic: ✔️
- Required: ❌
Password to use in case of basic auth
If not specified, won't use basic auth
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
- Dynamic: ❓
- Required: ❌
The count of executed queries
updatedCount
- Type: integer
- Dynamic: ❓
- Required: ❌
The updated rows count