Bulk load documents in ElasticSearch using Kestra Internal Storage file.

yaml
id: elasticsearch_load
namespace: company.team

inputs:
  - id: file
    type: FILE

tasks:
  - id: load
    type: io.kestra.plugin.elasticsearch.Load
    connection:
      hosts:
       - "http://localhost:9200"
    from: "{{ inputs.file }}"
    index: "my_index"

Dynamic NO

The connection properties.

Dynamic YES

The source file.

Dynamic YES

The elasticsearch index.

Dynamic YES

Default 1000

Dynamic YES

Use this key as id.

Dynamic YES

Possible Values

INDEXCREATEUPDATEDELETE

Sets the type of operation to perform.

Dynamic YES

Default true

Dynamic YES

Controls the shard routing of the request.

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

The size of the rows fetched.

SubType string

Dynamic YES

Min items 1

List of HTTP ElasticSearch servers.

Must be an URI like https://elasticsearch.com: 9200 with scheme and port.

Dynamic NO

Basic auth configuration.

SubType string

Dynamic YES

List of HTTP headers to be send on every request.

Must be a string with key value separated with : , ex: Authorization: Token XYZ.

Dynamic YES

Sets the path's prefix for every request used by the HTTP client.

For example, if this is set to /my/path, then any client request will become /my/path/ + endpoint. In essence, every request's endpoint is prefixed by this pathPrefix. The path prefix is useful for when ElasticSearch is behind a proxy that provides a base path or a proxy that requires all paths to start with '/'; it is not intended for other purposes and it should not be supplied in other scenarios.

Dynamic YES

Basic auth password.

Dynamic YES

Basic auth username.

​Load

Load