Batch Batch 

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

Execute a batch query to a Neo4j database.

# Examples

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

# bearerToken

  • Type: string
  • Dynamic: ✔️
  • Required: ❌

Token base64 encoded token

# chunk

  • Type: integer
  • Dynamic: ✔️
  • Required: ✔️
  • Default: 1000

The size of chunk for every bulk request

# from

  • Type: string
  • Dynamic: ✔️
  • Required: ✔️

Source file URI

# password

  • Type: string
  • Dynamic: ✔️
  • Required: ❌

Password to use in case of basic auth

If not specified, won't use basic auth

# 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.

# 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

The count of executed queries

# updatedCount

  • Type: integer

The updated rows count

← Query →

 Tweet  Share  Share