PluginsElasticsearchTasks

Bulk​Bulk

yaml
type: "io.kestra.plugin.elasticsearch.Bulk"

Bulk load documents in ElasticSearch using bulk files elastic files.

Examples

yaml
id: elasticsearch_bulk_load
namespace: company.team

inputs:
  - id: file
    type: FILE

tasks:
  - id: bulk_load
    type: io.kestra.plugin.elasticsearch.Bulk
    connection:
      hosts:
       - "http://localhost:9200"
    from: "{{ inputs.file }}"

Properties

connection

The connection properties.

from

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

The source file.

chunk

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

The chunk size for every bulk request.

routing

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

Controls the shard routing of the request.

Using this value to hash the shard and not the id.

Outputs

size

  • Type: integer
  • Required: ❌

Definitions

io.kestra.plugin.elasticsearch.ElasticsearchConnection

  • hosts
    • Type: array
    • SubType: string
    • Dynamic: ✔️
    • Required: ✔️
    • Min items: 1
  • basicAuth
  • headers
    • Type: array
    • SubType: string
    • Dynamic: ✔️
    • Required: ❌
  • pathPrefix
    • Type: string
    • Dynamic: ✔️
    • Required: ❌
  • strictDeprecationMode
    • Type: boolean
    • Dynamic: ❌
    • Required: ❌
  • trustAllSsl
    • Type: boolean
    • Dynamic: ❌
    • Required: ❌

io.kestra.plugin.elasticsearch.ElasticsearchConnection-BasicAuth

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