Elasticsearch Put
CertifiedIndex a document
Elasticsearch Put
Index a document
Indexes or creates a single document in an Elasticsearch index. Accepts a Map or JSON string for value. Default refresh policy is NONE; routing and opType are optional.
type: io.kestra.plugin.elasticsearch.PutExamples
Put a document with a Map
id: elasticsearch_put
namespace: company.team
tasks:
- id: put
type: io.kestra.plugin.elasticsearch.Put
connection:
hosts:
- "http://localhost:9200"
index: "my_index"
key: "my_id"
value:
name: "John Doe"
city: "Paris"
Put a document from a JSON string
id: elasticsearch_put
namespace: company.team
inputs:
- id: value
type: JSON
defaults: {"name": "John Doe", "city": "Paris"}
tasks:
- id: put
type: io.kestra.plugin.elasticsearch.Put
connection:
hosts:
- "http://localhost:9200"
index: "my_index"
key: "my_id"
value: "{{ inputs.value }}"
Properties
connection *RequiredNon-dynamic
Elasticsearch connection
Connection settings shared by tasks; hosts are required.
io.kestra.plugin.elasticsearch.ElasticsearchConnection
1Elasticsearch hosts
List of HTTP(S) endpoints including scheme and port, e.g. https://elasticsearch.com: 9200; at least one is required.
Basic authentication
Optional HTTP basic auth credentials rendered at runtime.
io.kestra.plugin.elasticsearch.ElasticsearchConnection-BasicAuth
Basic auth password
Password for HTTP basic authentication.
Basic auth username
Username for HTTP basic authentication.
Custom HTTP headers
Headers sent on every request in Name: Value format, e.g. Authorization: Token XYZ.
Request path prefix
Base path prepended to every Elasticsearch endpoint, e.g. /my/path. Use only when the cluster is served behind a proxy that requires a prefix; leave empty otherwise.
Fail on warning headers
When true, any response containing Elasticsearch warning headers is treated as an error.
8Target Elasticsearch server major version
Major version used for compatibility headers (Accept and Content-Type). Set to 8 for Elasticsearch 8 clusters or 9 for Elasticsearch 9 clusters.
Trust all SSL certificates
Skips certificate validation for HTTPS connections; use only with self-signed certificates in non-production.
index *Requiredstring
Target index
contentType string
JSONCBORJSONSMILEYAMLValue content type
Content type hint for value; default JSON.
key string
Document id
Optional _id; if omitted, Elasticsearch auto-generates one.
opType string
INDEXCREATEUPDATEDELETEOperation type
Allowed: INDEX or CREATE.
pluginDefaultsRef Non-dynamicstring
Reference (ref) of the pluginDefaults to apply to this task.
refreshPolicy string
NONEIMMEDIATEWAIT_UNTILNONERefresh policy
When to refresh the index after indexing: IMMEDIATE, WAIT_UNTIL, or NONE (default).
routing string
Custom shard routing
Optional routing key hashed to pick the shard instead of using the document id.
value object
Document body
Map or JSON string rendered at runtime and sent as the document source.
Outputs
id string
Document id
result string
CreatedUpdatedDeletedNotFoundNoOpIndexing result
version integer
Document version
