Batch

type: "io.kestra.plugin.neo4j.Batch"

Execute a batch query to a Neo4j database.

Examples

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

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
• Required: ❌

The count of executed queries

updatedCount

• Type: integer
• Required: ❌

The updated rows count

Definitions