Batch Batch

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

Execute a batch query to a Neo4j database.

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

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

Was this page helpful?