Elasticsearch Get
CertifiedRetrieve Elasticsearch document
Elasticsearch Get
Retrieve Elasticsearch document
Fetches a single document by index and id. Optionally enforces a version match and can fail when the document is missing.
type: io.kestra.plugin.elasticsearch.GetExamples
id: elasticsearch_get
namespace: company.team
tasks:
- id: get
type: io.kestra.plugin.elasticsearch.Get
connection:
hosts:
- "http://localhost:9200"
index: "my_index"
key: "my_id"
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
The Elasticsearch index
key *Requiredstring
Document id
docVersion integerstring
Expected version
GET succeeds only if the document version matches this value.
errorOnMissing booleanstring
falseFail when missing
If true, throws when the document is not found; default false.
pluginDefaultsRef Non-dynamicstring
Reference (ref) of the pluginDefaults to apply to this task.
routing string
Custom shard routing
Optional routing key hashed to pick the shard instead of using the document id.
Outputs
row object
Retrieved document
