Batch
Run a Neo4j batch-query.
Batch
Run a Neo4j batch-query.
Run a Neo4j batch-query.
yaml
type: "io.kestra.plugin.neo4j.Batch"Examples
yaml
id: neo4j_batch
namespace: company.team
tasks:
- 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
from*Requiredstring
Source file URI
Pebble expression referencing an Internal Storage URI e.g. {{ outputs.mytask.uri }}.
query*Requiredstring
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.
bearerTokenstring
Token base64 encoded token
chunkintegerstring
Default
1000The size of chunk for every bulk request
passwordstring
Password to use in case of basic auth
If not specified, won't use basic auth
urlstring
The URL to a Neo4j instance
The URL can either be in HTTP or Bolt format
usernamestring
Username to use in case of basic auth
If not specified, won't use basic
Outputs
rowCountinteger
The count of executed queries
updatedCountinteger
The updated rows count
Metrics
records.processedcounter
The total number of records processed in the batch.
records.updatedcounter
The total number of records updated in the batch.
