Load
yaml
type: "io.kestra.plugin.elasticsearch.load"Examples
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"
Properties
connection *RequiredNon-dynamicElasticsearchConnection
from *Requiredstring
index *Requiredstring
chunk integerstring
Default
1000idKey string
opType string
Possible Values
INDEXCREATEUPDATEDELETEremoveIdKey booleanstring
Default
truerouting string
Outputs
size integer
Definitions
io.kestra.plugin.elasticsearch.ElasticsearchConnection
hosts *Requiredarray
SubType string
Min items
1basicAuth ElasticsearchConnection-BasicAuth
headers array
SubType string