Load
yaml
type: "io.kestra.plugin.opensearch.load"
Examples
yaml
id: opensearch_load
namespace: company.team
inputs:
- id: file
type: FILE
tasks:
- id: load
type: io.kestra.plugin.opensearch.Load
connection:
hosts:
- "http://localhost:9200"
from: "{{ inputs.file }}"
index: "my_index"
Properties
connection *RequiredNon-dynamicOpensearchConnection
from *Requiredstring
index *Requiredstring
chunk integerstring
Default
1000
idKey string
opType string
Possible Values
INDEX
CREATE
UPDATE
DELETE
removeIdKey booleanstring
Default
true
routing string
Outputs
size integer
Definitions
io.kestra.plugin.opensearch.OpensearchConnection
hosts *Requiredarray
SubType string
basicAuth OpensearchConnection-BasicAuth
headers array
SubType string