Batch

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 *string

Source file URI

Pebble expression referencing an Internal Storage URI e.g. {{ outputs.mytask.uri }}.

query *string

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 string

Token base64 encoded token

chunk integerstring

Default 1000

The size of chunk for every bulk request

password string

Password to use in case of basic auth

If not specified, won't use basic auth

url string

The URL to a Neo4j instance

The URL can either be in HTTP or Bolt format

username string

Username to use in case of basic auth

If not specified, won't use basic

Outputs

rowCount integer

The count of executed queries

updatedCount integer

The updated rows count

​Batch

Batch